UpdateRecord
Описание
Обновляет содержимое FlowFile, содержащего данные, ориентированные на записи (то есть данные, которые могут быть прочитаны с помощью RecordReader и записаны с помощью RecordWriter). Этот процессор требует добавления как минимум одного пользовательского свойства. Имя свойства должно указывать RecordPath, который определяет поле, которое нужно обновить. Значение свойства является либо значением для замены (с возможностью использования языка выражений), либо самим RecordPath, который извлекает значение из записи. Определяется ли значение свойства как RecordPath или как буквальное значение, зависит от конфигурации свойства <Replacement Value Strategy>.
Теги
update, record, generic, schema, json, csv, avro, log, logs, freeform, text
Свойства
| Название | Описание |
|---|---|
| Record Reader | Указывает службу контроллера для чтения входящих данных |
| Record Writer | Указывает службу контроллера для записи данных |
| Replacement Value Strategy | Указывает, как интерпретировать настроенные значения замены. |
Взаимосвязи
- failure: Если FlowFile не может быть преобразован из настроенного входного формата в настроенный выходной формат, неизменный FlowFile будет отправлен в эту связь
- success: FlowFiles, которые были успешно преобразованы, будут отправлены в эту связь