flink 滑动窗口代码

Flink 中的滑动窗口可以通过以下代码实现：

DataStreamSource<String> source = env.socketTextStream("localhost", 9999);

// 定义滑动窗口，窗口大小为5，滑动步长为2
WindowedStream<String, Tuple, GlobalWindow> windowedStream = source
        .flatMap(new FlatMapFunction<String, Tuple2<String, Integer>>() {
            @Override
            public void flatMap(String value, Collector<Tuple2<String, Integer>> out) throws Exception {
                String[] words = value.split(" ");
                for (String word : words) {
                    out.collect(new Tuple2<>(word, 1));
                }
            }
        })
        .keyBy(0)
        .window(SlidingProcessingTimeWindows.of(Time.seconds(5), Time.seconds(2)));

// 计算每个窗口中每个单词的数量
SingleOutputStreamOperator<Tuple2<String, Integer>> result = windowedStream.sum(1);
result.print();

env.execute("Sliding Window Example");

在上面的代码中，`SlidingProcessingTimeWindows` 表示使用处理时间作为窗口的时间戳，并且定义了窗口的大小和滑动步长。`sum(1)` 表示对窗口中的单词数量进行累加。最后使用 `print()` 方法将结果打印出来，然后启动作业。