flink 滚动窗口 怎么指定时间字段

在 Flink 中使用滚动窗口时，可以通过指定时间戳抽取器来指定时间字段。时间戳抽取器是一个函数，用于从输入数据流中提取事件时间戳。可以使用 Flink 自带的 BoundedOutOfOrdernessTimestampExtractor 或者 AssignerWithPeriodicWatermarks，也可以自定义时间戳抽取器。在创建数据流后，可以通过调用DataStream.assignTimestampsAndWatermarks方法来指定时间戳抽取器，例如：

DataStream<MyEvent> stream = env
    .addSource(new FlinkKafkaConsumer<>(...))
    .assignTimestampsAndWatermarks(new BoundedOutOfOrdernessTimestampExtractor<MyEvent>(Time.seconds(10)) {
        @Override
        public long extractTimestamp(MyEvent event) {
            return event.getTimestamp();
        }
    });

在上面的示例中，BoundedOutOfOrdernessTimestampExtractor 从 MyEvent 对象中提取事件时间戳，并且指定了一个 10 秒的最大乱序时间。接下来可以通过调用DataStream.keyBy方法指定键值，然后调用window方法指定窗口类型和窗口大小，例如：

stream
    .keyBy(event -> event.getKey())
    .window(TumblingEventTimeWindows.of(Time.minutes(5)))
    .process(new MyWindowFunction());

在上面的示例中，使用keyBy方法将流按照某个属性分组，然后使用TumblingEventTimeWindows指定滚动窗口大小为 5 分钟。最后，使用process方法指定一个窗口函数，对窗口内的数据进行处理。