36、Flink 的 WindowAssigner之滑动窗口示例
1、处理时间 无需设置水位线策略和时间戳字段。 input.keyBy(e -> e).window(SlidingProcessingTimeWindows.of(Time.seconds(10), Time.seconds(5))).apply(new WindowFunction<String, String, String, TimeWindow>() {Overridepublic void apply(String s, TimeWi…
2025-09-05