Skip to main content

RecordMapper

描述:

允许将流映射成另一个。

标签:

map, avro, json, xml, flow

参数:

如下列表中,必填参数则标识为加粗. 其他未加粗参数,则表示为可选参数。表中同时提到参数默认值设置.

名字默认值允许值列表描述
记录读取者控制器服务API:
RecordReaderFactory
实现:
ParquetReader
GrokReader
SyslogReader
Syslog5424Reader
CSVReader
AvroReader
JsonPathReader
JsonTreeReader
ScriptedReader
XMLReader
指定用于读取输入数据的控制器服务。
记录写入者控制器服务API:
RecordSetWriterFactory
实现:
CSVRecordSetWriter
FreeFormTextRecordSetWriter
AvroRecordSetWriter
JsonRecordSetWriter
XMLRecordSetWriter
ParquetRecordSetWriter
ScriptedRecordSetWriter
指定用于写入记录的控制器服务。
Record JoinConfiguration of multi input recording connection
Join TimeoutIf the <Record Join> property is set to true, specifies how long to wait for all FlowFiles for a particular fragment.identifier attribute to arrive before just transferring all of the FlowFiles with that identifier to the 'failure' relationship
全局表达式变量将记录的表达式指定为变量,如果想处理记录路径的值,只需要提取一个变量,然后就可以使用表达式的方式进行处理。

动态参数:

名字描述
The name of a flow for input or output.the value is json format, which contained the settings for expression fields, avro schema, writer controller, expression vars, etc.支持自定义多流,并通过表达式对每个字段进行映射。
支持表达式语言 (支持流属性和变量)

连线:

名字描述
failure当由于某些原因映射失败时,会将流文件路由到此连线。
original被映射的原始流文件,如果流文件处理失败,则不会向此连线发送任何内容。

读取属性:

未提供。

写入属性:

未提供。

状态管理:

该组件不保存状态。

限制:

该组件没有限制

输入流要求:

组件必须提供输入流。

系统资源考量:

未提供。