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 Join | Configuration of multi input recording connection | ||
Join Timeout | If 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 | 被映射的原始流文件,如果流文件处理失败,则不会向此连线发送任何内容。 |
读取属性:
未提供。
写入属性:
未提供。
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。