AggregateRecord
描述:
在FlowFile的内容上执行SQL查询。此Processor从图形界面接收查询参数，然后执行对应的'SELECT'查询。支持列名重命名，简单的统计以及聚合操作等。本Processor只接受Avro格式的数据。如果FlowFile的内容格式不是Avro，可以使用ConvertRecord进行格式转换。如果有性能要求，建议使用QueryRecord。
标签:
sql, query, calcite, GUI, select, filter, record, avro, aggregate
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| 输出格式 | Avro | - CSV - Avro - JSON - XML | 输出数据格式 |
| schema内容 | Avro格式的schema内容.如果使用了界面提供的聚集函数和别名功能，此项必填，否则AggregateRecord将会尝试从输入数据和行筛选条件中推断出合适的schema 支持表达式语言 (仅支持变量) |
连线:
| 名字 | 描述 |
|---|---|
| success | 所有成功处理FlowFile的操作将被路由到此连线 |
| failure | 如果在FlowFile上执行的操作失败了，将路由到此连线 |
| original | 原始的输入数据流将被路由到此连线 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| mime.type | 将mime.type属性设置为Record Writer指定的值 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。