有没有办法在Flink中按照事件时间的顺序压缩两个或更多的流？

DataStream<Event> stream1 = ...; // 第一个流
DataStream<Event> stream2 = ...; // 第二个流

// 合并两个流
DataStream<Event> mergedStream = stream1.union(stream2);

// 分配Watermark和指示事件时间的逻辑
mergedStream = mergedStream.assignTimestampsAndWatermarks(new MyWatermarkAssigner());

// 按照key分组
KeyedStream<Event, Key> keyedStream = mergedStream.keyBy(new MyKeySelector());

// 创建KeyedProcessFunction实例并处理事件
keyedStream.process(new MyKeyedProcessFunction());

// 自定义WatermarkAssigner
public class MyWatermarkAssigner implements AssignerWithPeriodicWatermarks<Event> {
  @Nullable
  @Override
  public Watermark getCurrentWatermark() {
    // 返回当前Watermark
  }

  @Override
  public long extractTimestamp(Event event, long previousTimestamp) {
    // 提取事件时间
  }
}

// 自定义KeySelector
public class MyKeySelector implements KeySelector<Event, Key> {
  @Override
  public Key getKey(Event event) {
    // 返回事件的key
  }
}

// 自定义KeyedProcessFunction
public class MyKeyedProcessFunction extends KeyedProcessFunction<Key, Event, Result> {
  @Override
  public void processElement(Event event, Context ctx, Collector<Result> out) throws Exception {
    // 处理事件，可以访问事件时间并注册定时器
  }

  @Override
  public void onTimer(long timestamp, OnTimerContext ctx, Collector<Result> out) throws Exception {
    // 定时器触发时的处理逻辑，用于压缩缓存的事件
  }
}