發(fā)簡(jiǎn)信
IP屬地：四川
-
Windows遠(yuǎn)程桌面配置-有網(wǎng)的地方都可訪問(wèn)家里的電腦啰嗦的話放在最后，先上干貨。這篇文章僅為自己記錄參考，方便以后新電腦重新配置。有的步驟如果不懂，不會(huì)過(guò)多解釋。 需求 家里無(wú)法申請(qǐng)到公網(wǎng)ip，但...
-
Flink1.10.0與Hive3.1.2集成詳細(xì)步驟背景 Flink Hive 集成介紹 Flink集群設(shè)置 本地開(kāi)發(fā)調(diào)試本地開(kāi)發(fā)調(diào)試提示 Git相關(guān)項(xiàng)目 本文記錄了flink1.10.0與hiv...
-
Flink-Streaming-State & Fault Tolerance-Checkpointing
Flink中的每個(gè)function與operator都可以是有狀態(tài)的。有狀態(tài)的function會(huì)在處理每個(gè)數(shù)據(jù)時(shí)存儲(chǔ)數(shù)據(jù)，使得狀態(tài)state成為...
-
Flink-Streaming-State & Fault Tolerance-The Broadcast State Pattern
上篇講了operator state在恢復(fù)（重啟/故障恢復(fù)）時(shí)要么使用evenly distributed策略，要么使用union策略，來(lái)重啟o...
-
Flink-Streaming-State & Fault Tolerance-Working with State
這篇文檔解釋了如何在開(kāi)發(fā)應(yīng)用時(shí)，使用Flink的state。 Keyed State and Operator State 在Flink有兩種基...
-
Flink-Streaming-State & Fault Tolerance
OverviewWorking with StateThe Broadcast State PatternCheckpointingQuerya...
-
Flink-Streaming-State & Fault Tolerance-Overview
有狀態(tài)的函數(shù)和操作符會(huì)在處理數(shù)據(jù)時(shí)存儲(chǔ)一些數(shù)據(jù)，這使得state成為了任何想要進(jìn)行精細(xì)操作的操作符的關(guān)鍵組成部分。例如： 當(dāng)應(yīng)用尋找某些特定的模...
-
Flink-Streaming-EventTime-Pre-defined Timestamp Extractors / Watermark Emitters
Flink提供了接口，允許編程者自定義 timesatmp extractor 與 watermark emitter。更確切的說(shuō)，可以根據(jù)情況...
-
Flink-Streaming-EventTime-Generating Timestamps / Watermarks
這一部分文檔，只和使用 event time語(yǔ)義的應(yīng)用有關(guān)。為了使用 event time 語(yǔ)義，流程序需要設(shè)置相應(yīng)的 時(shí)間語(yǔ)義 time ch...