一、统一的数据处理组件栈，不仅能处理流处理，还可以用于批处理，机器学习，可以满足不同的用户的需求，对不同形式的计算进行了整合。 二、支持时间时间，接入时间，处理时间等时间概念...
IP属地：北京
-
定期删除Hive表的过期数据
定期删除Hive表的过期数据 由于Hive中有很多表都是每日全量的，数据量比较大，有些是可以将过去历史分区的数据进行删除的，所以需要一个定时执行的脚本，定时删除前七天的过期数...
-
SparkStreaming延迟监控
SparkStreaming延迟监控 这篇博客来源于一个惨痛的线上事故经历，我们编写好SparkStreaming程序清洗行为数据，然后每十分钟往Hive写一次，大家都以为任...
-
Linux环境下安装FLink1.10.0并启动SQL-client读取Hive1.2.1的数据
Linux环境下安装FLink1.10.0并启动SQL-client读取Hive数据 首先去官网下载Flink1.10.0的tgz的包，教程如上篇文章上半部分流程一样，然后配...
-
Window10安装Flink1.10.0-大坑
Window10安装Flink1.10.0 基本可以确定在window10安装Flink1.10.0启动时会出问题，特别恶心，目前无法修复，现在讲一讲我的踩坑经历。 首先我们...
-
Flink1.10.0读取并插入Hive1.2.1
FLink读取+插入Hive数据入坑指南 Flink1.9以上版本可以使用hivecatalog读取Hive数据，但是1.9对于Hive的版本支持不太友好，只支持2.3.4和...
-
Flink1.9.1写入Hbase1.1.2
这次试手Flink从kafka读数据写入hbase，遇到了很大的坑 1.我的程序是用Flink 1.9.1从本地kafka读取数据，写到本地hbase，本地zookeeper...
-
数据开发、数据分析、数据挖掘、算法研究、数据产品！
-
-
Go资料的一些笔记，常用包的介绍和例子，没有编程基础也可食用 (投稿一直没处理可以给管理员发私信，一般会尽量尽早处理的，多谢支持）
-
产品经理 on the GO!
