flink session window窗口合併

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