如何获取一分钟处理窗口的最新记录

"我有一个利用Windows的flink流媒体工作。

我的目标是id在一分钟内按内部收到的记录进行分组，然后仅按最新记录流式传输记录id。

我想出了两种可能的方法：

运用 reduce()

stream.keyBy(Record::getId)

.window(TumblingProcessingTimeWindows.of(Time.seconds(60)))
.reduce((rec1, rec2) -> rec2);

这工作得很好，但似乎浪费，因为它要求每个和每一个记录。

运用 process()

stream.keyBy(Record::getId)

.window(TumblingProcessingTimeWindows.of(Time.seconds(60)))
.process(new ProcessWindowFunction<Record, Object, Long, TimeWindow>() {
    @Override
    public void process(Long aLong, Context context, Iterable<Record> iterable, Collector<Object> collector) throws Exception {
        Record last = null;
        for (Record rec : iterable) {
            if (last == null || last.getTimestamp() < rec.getTimestamp()) {
                last = rec;
            }
        }
        collector.collect(last);
    }
});

这也可以正常工作。我曾预料到它会更快，但事实并非如此（它与解决方案1大致相同）。

你能推荐一个更好的方法吗？"