Flink中window Trigger的理解

初識Flink,對於window相關的幾個概念不甚瞭解,先拋出幾個關鍵問題!java window是如何劃分的? watermark生成方式?多久產生一次? window觸發計算條件? 延遲數據如何處理? 1、window是如何劃分的? window的劃分與數據自己無關,而是由系統定義好的。web dataStreamSource.flatMap(new MyFlatMapFunction())
相關文章
相關標籤/搜索