flink session window窗口合併

  flink session window窗口的條件是元素間隔大於gap 還是 大於等於gap?session window是怎麼進行合併的?還是通過官方示例:org.apache.flink.streaming.examples.windowing.SessionWindowing 進行分析: 主要是修改了下數據源,首先添加8這條數據執行結果如下: 從結果可以看出 b 都在同一個窗口計算。再將
相關文章
相關標籤/搜索