時間ウィンドウ関数
時間ウィンドウ関数は、対応するウィンドウの下側の境界(含む)と上側の境界(含まない)を返します。 WindowView を扱うための関数は以下に示します。
hop
導入バージョン: v21.12
ホッピング時間ウィンドウは固定の長さ(window_interval)を持ち、指定されたホップ間隔(hop_interval)ごとにシフトします。hop_interval が window_interval より小さい場合、ホッピングウィンドウは互いに重なり合います。そのため、レコードは複数のウィンドウに割り当てられる可能性があります。
1 つのレコードが複数の hop ウィンドウに割り当てられる可能性があるため、WINDOW VIEW を使用せずに hop 関数を使用した場合、この関数は最初のウィンドウの境界のみを返します。
構文
引数
time_attr— 日付と時刻。DateTimehop_interval— 正のホップ間隔。Intervalwindow_interval— 正のウィンドウ間隔。Intervaltimezone— 省略可。タイムゾーン名。String
戻り値
対応するホッピングウィンドウの下限(包含的)と上限(排他的)を返します。Tuple(DateTime, DateTime)
例
ホッピングウィンドウ
hopEnd
導入バージョン: v22.1
対応するホップウィンドウの排他的上限を返します。
1 つのレコードが複数のホップウィンドウに割り当てられる可能性があるため、WINDOW VIEW なしで hop 関数を使用する場合、この関数は最初のウィンドウの境界のみを返します。
構文
引数
time_attr— 日付と時刻。DateTimehop_interval— 正のホップ間隔。Intervalwindow_interval— 正のウィンドウ間隔。Intervaltimezone— 省略可能。タイムゾーン名。String
戻り値
対応するホッピングウィンドウの排他的上限値を返します。DateTime
例
ホッピングウィンドウの終端
hopStart
導入バージョン: v22.1
対応するホップウィンドウの包含的な下限値を返します。
1 つのレコードが複数のホップウィンドウに割り当てられる可能性があるため、WINDOW VIEW を使用せずに hop 関数を使用した場合、この関数は最初のホップウィンドウの下限値のみを返します。
構文
引数
time_attr— 日付と時刻。DateTimehop_interval— 正のホップ間隔。Intervalwindow_interval— 正のウィンドウ間隔。Intervaltimezone— 省略可。タイムゾーン名。String
戻り値
対応するホッピングウィンドウの下側の(含まれる)境界を返します。DateTime
例
ホッピングウィンドウの開始
tumble
導入バージョン: v21.12
タンブリングウィンドウは、レコードを固定長(interval)の、互いに重ならない連続したウィンドウに割り当てます。
構文
引数
戻り値
対応するタンブリングウィンドウの下限(含む)と上限(含まない)を返します。Tuple(DateTime, DateTime)
例
タンブリングウィンドウ
tumbleEnd
導入バージョン: v22.1
対応するタンブリングウィンドウの非包含の上限値を返します。
構文
引数
time_attr— 日付と時刻。DateTimeinterval—Interval型で指定されたウィンドウ間隔。Intervaltimezone— 省略可能。タイムゾーン名。String
戻り値
対応するタンブリングウィンドウの排他的な上限値を返します。DateTime
例
タンブリングウィンドウの終了時刻
tumbleStart
導入: v22.1
対応するタンブリングウィンドウの包含的な下限を返します。
構文
引数
time_attr— 日付と時刻。DateTimeinterval— Interval 型で指定するウィンドウ間隔。Intervaltimezone— オプション。タイムゾーン名。String
返り値
対応するタンブリングウィンドウの包括的な下限(開始時刻)を返します。DateTime
例
タンブリングウィンドウの開始