Skip to main content

UpdateRecord

描述:

更新包含原始记录数据的数据流内容(即,可以通过读取服务读取并由写入服务写入的数据)。 此处理器要求至少添加一个用户自定义的属性。 自定义属性的名称与RecordPath相对应,该RecordPath确定应更新的字段。 自定义属性的值是替换值(可选地使用表达式语言)或者本身是从记录中提取值的RecordPath。 自定义属性值是RecordPath还是字符串取决于<值替换策略>属性的配置。

标签:

update, 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
指定用于写出记录的服务
值替换策略字面值
- 字面值输入的属性值(在计算表达式之后)是更新记录字段所需的值。 表达式语言可以引用变量&#39;field.name&#39;,&#39;field.type&#39;和&#39;field.value&#39;来访问有关字段和正在匹配的字段的值的信息。
- RecordPath值输入的属性值(在计算表达式语言之后)不是要使用的字符串,而是应该根据RecordPath计算值,RecordPath的结果将用于更新记录。 请注意,如果选择此选项,并且RecordPath导致给定记录的多个值,则输入数据流将输出到“failure”连线。
指定如何解释配置的替换值

连线:

名字描述
success成功转换的数据流将输出到此连线
failure如果无法将数据流从配置的输入格式转换为配置的输出格式,将未更改的输入流输出到此连线

读取属性:

未提供。

写入属性:

未提供。

状态管理:

该组件不保存状态。

限制:

该组件没有限制

输入流要求:

组件必须提供输入流。

系统资源考量:

未提供。

参考:

ConvertRecord