使用Apache Flink，我如何穿插一個流，以便在空窗口上發射數值

Question

我正在一小時窗口中聚合數據。當一小時內沒有事件到達時，不會調用聚合函數，也不會計算零聚合。因此，我的輸出會錯過用於顯示窗口的條目。有沒有簡單的方法來確保計算空窗口以便我能夠發出零聚合？

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

Answer 1

目前，Flink不支持空窗口。在內部，必須至少有一個屬於窗口的元素才能創建它。