Record Sorter By Time

对每一个批次中的records按照时间字段 /time 进行升序排序。

该算子不支持血缘解析。

配置详情

该算子的配置包括 GeneralBasic 的详细信息,各字段的配置如下:

General

名称

是否必须

描述

Name

Yes

算子名称

Description

No

算子描述

Stage Library

Yes

算子所属的库

Required Fields

No

数据必须包含的字段,如果未包含指定字段,则record将被过滤掉

Preconditions

No

数据必须满足的前提条件,如果不满足指定条件,则record将被过滤掉。例如:${record:value('/value') > 0}。有关EL语句的使用方法,参考 Expression Language

On Record Error

Yes

对错误数据的处理方式,可选:

  • Discard:直接丢弃

  • Send to Error:发送至错误中心

  • Stop Pipeline:停止流任务运行

Basic

名称

是否必须

描述

Quality Filter

No

根据数据质量过滤处理数据,只有符合质量条件的record才会进行此次处理

输出结果

该算子的输出结果为经过排序过后的streaming records。

输出示例

按照时间字段进行排序前

../../../_images/time_sort_result1.png

按照时间字段进行排序后

../../../_images/time_sort_result_11.png