apache-flink - 如何按时间排序或加入 KeyedStream？

Question

我有一个使用keyBy然后flatMap的数据流。如何将输出写入队列并保留所有键的时间顺序？

dataSrc // just a stream of longs
    .keyBy(value -> value % 4)
    .window(TumblingEventTimeWindows.of(Time.minutes(1)))
    .flatMap((value1, value2) -> 
        {
            if (value2.longValue > value1.longValue) {
                return value2;
            }
            return value1;
        });
  

标签： apache-flink