ConvertRecord

描述:

使用配置的记录读取服务和写入服务将记录从一种数据格式转换为另一种数据格式。 读取和写入服务必须使用匹配模式（schema）。 模式必须具有相同的字段名称。 如果字段值可以从一种类型强制转换为另一种类型，则字段的类型可不必相同。 例如，如果输入模式具有double类型的名为“balance”的字段，则输出模式可以具有名为“balance”的字段，其类型可为字符串，double或float。 如果输入中存在输出中不存在的任何字段，则该字段将被排除在输出之外。 如果在输出模式中指定了任何字段但输入数据/模式中不存在该字段，则该字段将不会出现在输出中，或者具有空值，具体取决于写入服务。

标签:

convert, record, generic, schema, json, csv, avro, log, logs, freeform, text, 转换, 记录

参数:

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

名字	默认值	允许值列表	描述
记录读取服务		控制器服务API: RecordReaderFactory 实现: ParquetReader GrokReader SyslogReader Syslog5424Reader CSVReader AvroReader JsonPathReader JsonTreeReader ScriptedReader XMLReader	指定用于读取数据的服务
记录写入服务		控制器服务API: RecordSetWriterFactory 实现: CSVRecordSetWriter FreeFormTextRecordSetWriter AvroRecordSetWriter JsonRecordSetWriter XMLRecordSetWriter ParquetRecordSetWriter ScriptedRecordSetWriter	指定用于输出数据的服务
Include Zero Record FlowFiles	true	- true - false	When running the SQL statement against an incoming FlowFile, if the result has no data, this property specifies whether or not a FlowFile will be sent to the corresponding relationship

连线:

名字	描述
success	转换数据流格式成功后输出数据流到此连线
failure	如果无法将数据流从配置的输入格式转换为输出格式，则原始输入数据流将输出到此连线

读取属性:

未提供。

写入属性:

名字	描述
mime.type	将mime.type属性设置为写入服务指定的MIME类型
record.count	数据流的输出记录数

状态管理:

该组件不保存状态。

限制:

该组件没有限制

输入流要求:

组件必须提供输入流。

系统资源考量:

未提供。