使用Apache Flink，我如何穿插一个流，以便在空窗口上发射数值

Question

我正在一小时窗口中聚合数据。当一小时内没有事件到达时，不会调用聚合函数，也不会计算零聚合。因此，我的输出会错过用于显示窗口的条目。有没有简单的方法来确保计算空窗口以便我能够发出零聚合？

Events   -> A - - B - C - - - - - - E - F - 
Desired output -> [  2][ 1][  0][  2] 
Observed pr now -> [  2][ 1]  [  2] 

Answer 1

目前，Flink不支持空窗口。在内部，必须至少有一个属于窗口的元素才能创建它。