跳转至

Time bounded event time sort（时间有界事件时间排序（Time bounded event time sort））

Supported in: Streaming

Emits rows by key in ascending event time order, allowing for late arriving records up until at least the allowed lateness. Records arriving after the allowed lateness plus some small buffer interval will be dropped.

Transform categories: Other

Declared arguments

  • Allowed lateness time unit: Unit for amount of time to wait for late arriving records to be sorted.
    Enum\
  • Allowed lateness time value: Value for amount of time to wait for late arriving records to be sorted.
    Literal\
  • Dataset: Dataset to sort rows.
    Table
  • optional Key by columns: Columns on which to partition the input by key. Each sort will be computed separately for each distinct key value.
    Set\>

中文翻译

时间有界事件时间排序（Time bounded event time sort）

支持：流式处理（Streaming）

按事件时间升序输出行，允许延迟到达的记录在允许的最大延迟时间内被处理。超过允许延迟时间加上少量缓冲间隔的记录将被丢弃。

转换类别：其他

声明参数

  • 允许延迟时间单位（Allowed lateness time unit）： 等待延迟到达记录进行排序的时间单位。
    枚举类型\<天、小时、毫秒、分钟、秒、周>
  • 允许延迟时间值（Allowed lateness time value）： 等待延迟到达记录进行排序的时间数值。
    字面量\<长整型>
  • 数据集（Dataset）： 需要排序行的数据集。
    表
  • 可选 按键列（Key by columns）： 用于按键对输入进行分区的列。每个不同的键值将分别计算各自的排序结果。
    集合\<任意类型列>