Apache Flinkでは、空のウィンドウに値が出力されるようにストリームをどのように交差させることができますか？

Question

1時間のウィンドウでデータを集計しています。 1時間以内にイベントが到着しなかった場合、agggregating関数は呼び出されず、ゼロ集計は決して計算されません。したがって、私の出力はemtpyであるウィンドウのエントリを見落とします。空のウィンドウも計算されていることを確認する簡単な方法はありますか？私はゼロ集計を出すことができますか？

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

Answer 1

現在、Flinkは空のウィンドウをサポートしていません。内部的には、ウィンドウを作成するために少なくとも1つの要素がウィンドウに属している必要があります。