時間ウィンドウ関数
時間ウィンドウ関数は、対応するウィンドウの包含下限と排他上限を返します。 WindowView を操作するための関数は以下に示されています。
tumble
タンブル時間ウィンドウは、固定の期間(interval
)を持つ非重複の連続したウィンドウにレコードを割り当てます。
構文
引数
返される値
例
クエリ:
結果:
tumbleStart
対応する タンブルウィンドウ の包含下限を返します。
構文
引数
返される値
例
クエリ:
結果:
tumbleEnd
対応する タンブルウィンドウ の排他上限を返します。
構文
引数
返される値
例
クエリ:
結果:
hop
ホッピング時間ウィンドウは、固定の期間(window_interval
)を持ち、指定されたホップ間隔(hop_interval
)ごとにホップします。 hop_interval
が window_interval
より小さい場合、ホッピングウィンドウは重複します。したがって、レコードは複数のウィンドウに割り当てることができます。
引数
time_attr
— 日付と時刻。 DateTime.hop_interval
— 正のホップ間隔。 Interval.window_interval
— 正のウィンドウ間隔。 Interval.timezone
— タイムゾーン名 (オプション)。
返される値
1つのレコードが複数のホップウィンドウに割り当てられる可能性があるため、ホップ関数が WINDOW VIEW なしで使用される場合、関数は 最初の ウィンドウの境界のみを返します。
例
クエリ:
結果:
hopStart
対応する ホッピングウィンドウ の包含下限を返します。
構文
引数
time_attr
— 日付と時刻。 DateTime.hop_interval
— 正のホップ間隔。 Interval.window_interval
— 正のウィンドウ間隔。 Interval.timezone
— タイムゾーン名 (オプション)。
返される値
1つのレコードが複数のホップウィンドウに割り当てられる可能性があるため、ホップ関数が WINDOW VIEW なしで使用される場合、関数は 最初の ウィンドウの境界のみを返します。
例
クエリ:
結果:
hopEnd
対応する ホッピングウィンドウ の排他上限を返します。
構文
引数
time_attr
— 日付と時刻。 DateTime.hop_interval
— 正のホップ間隔。 Interval.window_interval
— 正のウィンドウ間隔。 Interval.timezone
— タイムゾーン名 (オプション)。
返される値
1つのレコードが複数のホップウィンドウに割り当てられる可能性があるため、ホップ関数が WINDOW VIEW なしで使用される場合、関数は 最初の ウィンドウの境界のみを返します。
例
クエリ:
結果: