A表 left join B表后的结果写入upsert-kafka,下游统计时如何在窗口内获取到最新

一般情况下，在下游使用窗口操作的时候，都是根据某个字段作为窗口的起始时间或者结束时间，然后每条记录进入窗口时被聚合或者处理。

因此，在这种情况下，如果需要在窗口内获取到最新的数据，则可以使用先进先出的窗口。在 Flink 中，先进先出窗口就是 EvictingWindowOperator。

首先，在 A 表 left join B 表后，使用 EvictingWindowOperator 对数据流进行窗口操作，设置窗口大小为 1，窗口先进先出，每个窗口执行一个最新的数据。具体使用方法如下：

A_B_Table
  .window(EvictingWindowOperator.of(Count.of(1), OverflowPolicy.FIRE_AND_PURGE))
  .reduce((v1, v2) -> v2)
  .addSink(...);