時間制限付き重複行削除

対応している: ストリーミング

指定された行のサブセットに対して、入力から重複行を削除します。行の有効期限は、設定されたイベント時間の量が経過すると切れます。設定されたイベント時間の量よりも遅れて到着する行は常に削除されます。指定されたキーでパーティションを分割します。それぞれの重複削除は、異なるキー行の値ごとに別々に計算されます。 変換カテゴリ: その他

宣言された引数

• データセット - 重複行を削除するデータセット
  テーブル
• キー有効期限時間単位 - データの重複削除を待つ時間の単位
  Enum<Days, Hours, Milliseconds, Minutes, Seconds, Weeks>
• キー有効期限時間値 - データの重複削除を待つ時間の値
  Literal<Long>
• オプション 行サブセット - 指定された行がある場合、それらのみが一意性の判断に使用されます。
  Set<行<AnyType>>
• オプション キー別行 - 入力をキー別に分割する行。それぞれの重複削除は、異なるキー値ごとに並行して別々に計算されます。
  Set<行<AnyType>>