flink Windowsを起動するとき

Question

私はApache Flink からすべての「自然な」時間のイベントを取得したいと考えています。それは

は、私が使用している...私は夜1時00分00秒午後01時59分59秒まで、12時59分59秒までの12時○○分00秒からのウィンドウでイベントをキャプチャしたい、次のとおりです。

datastream.keyBy(0) 
.timeWindow(Time.minutes(60)) 

しかし、60分が毎時に始まることをどのように知っていますか？ウィンドウは、たとえば12:30から13:29:59までではありません。

Answer 1

回答はhereです。要約すると：

タンブリングおよびスライドウィンドウの場合、ウィンドウはエポック（1970年1月1日00:00:00）に揃えられます。したがって、オフセットのパラメータを変更しないと、タンブリングウィンドウが "時"に一致します。