flink如何使用WatermarkStrategy.forBoundedOutOfOrderness中的withTimestampAssigner()

在 Flink 中，使用 `WatermarkStrategy.forBoundedOutOfOrderness()` 方法创建一个基于事件时间的 WatermarkStrategy，你可以通过 `withTimestampAssigner()` 方法为该策略指定一个时间戳分配器。该方法接受一个实现 `TimestampAssigner` 接口的对象，用于从事件中抽取事件时间。下面是一个使用 `withTimestampAssigner()` 的例子：

DataStream<MyEvent> events = ...;

WatermarkStrategy<MyEvent> watermarkStrategy =
    WatermarkStrategy.<MyEvent>forBoundedOutOfOrderness(Duration.ofSeconds(10))
        .withTimestampAssigner((event, timestamp) -> event.getEventTime());

DataStream<MyEvent> eventsWithTimestampsAndWatermarks =
    events.assignTimestampsAndWatermarks(watermarkStrategy);

在上面的例子中，我们创建了一个基于事件时间的 WatermarkStrategy，并通过 `withTimestampAssigner()` 方法指定了一个时间戳分配器，该分配器从 `MyEvent` 事件中提取事件时间。最后，我们将该策略应用于数据流中的每个事件，以便为每个事件分配事件时间戳和水印。