Flink计算每10秒的时间点某个状态的数据有多少咋弄啊？

博主可以参考下这个代码

public class StreamWordCount {
    public static void main(String[] args) throws Exception {
        //创建执行环境
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        //设置并行度
        env.setParallelism(1);
 
        //DataSource操作
        DataStreamSource<String> sourceStream = env.socketTextStream("192.168.153.10", 6666);
 
        //通过匿名内部类的方式实现flatMap算子
        final SingleOutputStreamOperator<Tuple2<String, Integer>> flatMapStream = sourceStream.flatMap(new FlatMapFunction<String, Tuple2<String, Integer>>() {
            @Override
            public void flatMap(String line, Collector<Tuple2<String, Integer>> collector) throws Exception {
                final String[] words = line.split(" ");
                for (String word : words) {
                    collector.collect(new Tuple2<>(word, 1));
                }
            }
        });
        //keyBy分组操作
        final KeyedStream<Tuple2<String, Integer>, String> keyedStream = flatMapStream.keyBy(value -> value.f0);
        //每隔5秒，统计最近10秒的窗口数据
        WindowedStream<Tuple2<String, Integer>, String, TimeWindow> window = keyedStream.window(SlidingProcessingTimeWindows.of(Time.seconds(10), Time.seconds(5)));
        //sum求和操作
        final SingleOutputStreamOperator<Tuple2<String, Integer>> result = window.sum(1);
 
        //输出结果
        result.print();
 
        //执行程序
        env.execute("StreamWordCount");
    }
}