flink session window窗口合并

  flink session window窗口的条件是元素间隔大于gap 仍是 大于等于gap?session window是怎么进行合并的?仍是经过官方示例:org.apache.flink.streaming.examples.windowing.SessionWindowing 进行分析:apache 主要是修改了下数据源,首先添加8这条数据执行结果以下:session 从结果能够看出 b
相关文章
相关标签/搜索