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 | 指定用于写出记录的服务 | |
值替换策略 | 字面值 | - 字面值 - RecordPath值 | 指定如何解释配置的替换值 |
连线:
名字 | 描述 |
---|---|
success | 成功转换的数据流将输出到此连线 |
failure | 如果无法将数据流从配置的输入格式转换为配置的输出格式,将未更改的输入流输出到此连线 |
读取属性:
未提供。
写入属性:
未提供。
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。