鄭重聲明：本文系原創(chuàng)首發(fā)，文責(zé)自負(fù)。 本文參與伯樂聯(lián)合征文【品】之回望[http://www.itdecent.cn/p/92961615be20]主題活動。 1998年，...
IP屬地：北京
-
Flink 維表Join/雙流Join 方法總結(jié)一、背景 事實表通常存儲在kafka中，維表通常存儲在外部設(shè)備中(比如MySQL，HBase)。對于每條流式數(shù)據(jù)，可以關(guān)聯(lián)一個外部維表數(shù)據(jù)源，為實時計算提供數(shù)據(jù)關(guān)聯(lián)查詢。維表...
-
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
環(huán)境 CDH-6.3.2Flink-1.12.2最后會補充說明Flink-1.13.1的使用方法 準(zhǔn)備 在flink-1.12.2/lib目錄需要放如下jar包 啟動Flin...
-
Flink State、CheckPoint與Savepoint、Flink的Exactly OnceState State簡述 State分類： Keyed state Operator state State兩種形態(tài)： Raw State（原始狀態(tài)）只需要繼承RichFu...
