注: 以下の翻訳の正確性は検証されていません。AIPを利用して英語版の原文から機械的に翻訳されたものです。

時間制限付きイベント時間並べ替え

対応: ストリーミング

キーごとにイベント時間の昇順で行を出力し、許容される遅延時間までは遅れて到着するレコードを受け入れます。許容される遅延時間とわずかなバッファ間隔を超えて到着するレコードは破棄されます。

トランスフォームカテゴリ: その他

引数

  • 許容遅延時間単位 - 遅れて到着するレコードを並べ替えるまで待機する時間の単位。
    Enum<Days, Hours, Milliseconds, Minutes, Seconds, Weeks>
  • 許容遅延時間値 - 遅れて到着するレコードを並べ替えるまで待機する時間の値。
    Literal<Long>
  • データセット - 行を並べ替えるデータセット。
    Table
  • オプション 列でキー指定 - 入力をキーでパーティション分割するための列。各並べ替えは各異なるキー値ごとに別々に計算されます。
    Set<Column<AnyType>>