20篇文章 · 20458字 · 3人關注
-
Flink 窗口觸發(fā)器解析
1.前言 窗口的觸發(fā)器定義了窗口是何時被觸發(fā)并同時決定觸發(fā)行為（對窗口進行清理或者計算）瓢娜。注意：窗口的觸發(fā)在內部是設置定時器來實現的。 2. 觸...
-
Flink 窗口分配器解析1 前言 WindowAssigner：用于給當前流中元素分配0個或者多個窗口相關的抽象方法就是assignWindows梢杭，該方法為某個帶有時間...
-
[Flink State] State究竟保存在哪里破加？1.前言 從源碼解析State的保存過程钢坦，上一篇從task和operator出發(fā)說明了保存state的過程某筐，到最后是由算子調用snapshot方...
-
[Flink State] 從源碼解析State的保存過程1 前言 State要能發(fā)揮作用比搭，就需要持久化到可靠存儲中，flink中持久化的動作就是checkpointing南誊，那么從TM中執(zhí)行的Task的...
-
Flink中與流廣播配合使用的readFile解析1. 前言 最近有需求要定時監(jiān)控文件身诺，如果文件內容發(fā)生變化蔽莱，就要動態(tài)地獲取新內容，于是就準備使用 env.readFile方法戚长，（1）當你監(jiān)控一...
-
Flink在加載文件數據源時，如何創(chuàng)建分片呢怠苔？主要分析FileInputFormat類的createInputSplits方法 參數minNumSplits同廉，通常是readFile等讀取文件...
-
Flink Parallelism和Slot理解相關博客：Flink工作原理 1 問題出現 Caused by: akka.pattern.AskTimeoutException:Ask ti...
-
Flink Window觸發(fā)機制
1. Flink的Window類型 Flink基本分有3種window類型：CountWindow，TimeWindow和SessionWind...
-
窗口實用觸發(fā)器 ContinuousEventTimeTrigger
短窗口的計算由于其窗口期較短柑司，那么很快就能獲取到結果迫肖，但是對于長窗口來說短窗口時間比較長，如果等窗口期結束才能看到結果攒驰，那么這份數據就不具備實時...
