郑重声明：本文系原创首发，文责自负。 本文参与伯乐联合征文【品】之回望[https://www.jianshu.com/p/92961615be20]主题活动。 1998年，...
IP属地：北京
-
Flink 维表Join/双流Join 方法总结一、背景 事实表通常存储在kafka中，维表通常存储在外部设备中(比如MySQL，HBase)。对于每条流式数据，可以关联一个外部维表数据源，为实时计算提供数据关联查询。维表...
-
Spark Structured Streaming写Hive HBase Mysql
组件版本 spark版本 2.3.1 (hdp) hadoop 3.1.1 (hdp) HDP hive 3.1.2 HBase 2.0.0 mysql 版本5.x 使用Sp...
-
Flink SQL Client集成Hive
环境 CDH-6.3.2Flink-1.12.2最后会补充说明Flink-1.13.1的使用方法 准备 在flink-1.12.2/lib目录需要放如下jar包 启动Flin...
-
Flink State、CheckPoint与Savepoint、Flink的Exactly OnceState State简述 State分类： Keyed state Operator state State两种形态： Raw State（原始状态）只需要继承RichFu...
