Skip to main content

SortRecord

对输入的AVRO,JSON,TEXT格式的数据流的内容进行排序,按照指定的字段表达式来定义排序规则,并将排序后的数据流放入数据流内容输出。

参数说明

1,SORT_EXPRESSION 排序表达式: 排序表达式格式为字段名加#加排序类型,TEXT格式由于没有字段名所以可以直接用号代替字段名,或者不填写字段名加#号方式即可 例如:favorite_number#desc,favorite_color#asc 此表达式表示字段名favorite_number按照desc倒序排序, 再按照字段名favorite_color以asc升序排序,如果对TEXT文本排序则表达式如下:#asc 或 *#desc 或者#asc方式也可以

2,DATA_TYPE 数据类型: 下拉列表选择,共有三种模式,AVRO,JSON,TEXT,根据需要自行选择即可

###使用方法 1,准备json数据,添加一个GenerateFlowFile组件,配置属性如下图所示:

2,添加sortRecord组件,配置属性如下图所示:

3,整体组件流程如下图所示:

目标输出

  • 数据流内容,将排序结果作为新数据流内容输出,原数据流内容将被替换掉

流程模板

参见附件(请右键另存保存):模板文件

参见附件(请右键另存保存):SortRecord组件测试