時間の上部にあるデータフロー固定ウィンドウ

Question

データフローストリーミングジョブのウィンドウを1時間ごとに開始し終了するように設定する方法はありますか？私は現在、1時間の固定ウィンドウを使用していますが、ジョブの開始時に開始され、そこから1時間単位で表示されます。ありがとうございました。

Answer 1

固定ウィンドウは、特定の長さのウィンドウ（期間）を表します。毎時の先頭から始まるウィンドウは、時間に応じて可変長（例えば、閏秒など）を持つことがあります。

カレンダーウィンドウでは、暦日、月などのウィンドウが提供されます。

あなたのユースケースでは、自分のタイムスタンプに基づいて要素を時間に始まり、時間の終わりまで伸びるウィンドウに割り当てる独自のWindowFnを書くことができます。

このようなWindowFnは、Apache Beam SDKにとって有用なものです。問題を提出し、実装に貢献することを検討してください。