hop
導入バージョン: v21.12.0 ホッピング時間ウィンドウは、固定長の (window_interval) を持ち、指定したホップ間隔 (hop_interval) ごとに移動します。hop_interval が window_interval より小さい場合、ホッピングウィンドウは重なります。そのため、レコードは複数のウィンドウに割り当てられることがあります。
1 つのレコードが複数の hop ウィンドウに割り当てられる可能性があるため、この関数は最初のウィンドウの境界のみを返します。
構文
time_attr— 日付と時刻。DateTimehop_interval— 正のホップ間隔。Intervalwindow_interval— 正のウィンドウ間隔。Intervaltimezone— 任意。タイムゾーン名。String
Tuple(DateTime, DateTime)
例
ホッピングウィンドウ
Query
Response
hopEnd
導入バージョン: v22.1.0 対応するホッピングウィンドウの上限を返します。 1 つのレコードは複数のhop ウィンドウに割り当てられる可能性があるため、この関数は最初のウィンドウの境界のみを返します。 構文time_attr— 日付と時刻。DateTimehop_interval— 正のホップ間隔。Intervalwindow_interval— 正のウィンドウ間隔。Intervaltimezone— 任意。タイムゾーン名。String
DateTime
例
ホッピングウィンドウの終了時刻
Query
Response
hopStart
導入バージョン: v22.1.0 対応するホッピングウィンドウの下限を返します。 1 つのレコードは複数の hop ウィンドウ に割り当てられる可能性があるため、この関数は最初のウィンドウの境界のみを返します。 構文time_attr— 日付と時刻。DateTimehop_interval— 正のホップ間隔。Intervalwindow_interval— 正のウィンドウ間隔。Intervaltimezone— 任意。タイムゾーン名。String
DateTime
例
ホッピングウィンドウの開始
Query
Response
tumble
導入バージョン: v21.12.0 タンブリング時間ウィンドウでは、レコードは固定長 (interval) の、重複しない連続したウィンドウに割り当てられます。
構文
Tuple(DateTime, DateTime)
例
タンブリングウィンドウ
Query
Response
tumbleEnd
導入バージョン: v22.1.0 対応するタンブリングウィンドウの上限を返します。 構文DateTime
例
タンブリングウィンドウの終端
Query
Response
tumbleStart
導入バージョン: v22.1.0 対応するタンブリングウィンドウの下限を返します。 構文DateTime
例
タンブリングウィンドウの開始
Query
Response