ConvertRecord
Описание
Преобразует записи из одного формата данных в другой, используя настроенные службы контроллера Record Reader и Record Write. Читатель и писатель должны быть настроены на «соответствующие» схемы. Это означает, что схемы должны иметь одинаковые имена полей. Типы полей могут не совпадать, если значение поля может быть преобразовано из одного типа в другой. Например, если входная схема имеет поле с именем «balance» типа double, выходная схема может иметь поле с именем «balance» с типом string, double или float. Если какое-либо поле присутствует во входных данных, но отсутствует в выходных, это поле не будет включено в выходные данные. Если какое-либо поле указано в выходной схеме, но отсутствует во входных данных/схеме, то поле не будет присутствовать в выходных данных или будет иметь значение null, в зависимости от настроек писателя.
Теги
convert, record, generic, schema, json, csv, avro, log, logs, freeform, text
Свойства
Название | Описание |
---|---|
Record Reader | Указывает службу контроллера для чтения входящих данных |
Record Writer | Указывает службу контроллера для записи данных |
Include Zero Record FlowFiles | При преобразовании входящего FlowFile, если в результате преобразования не будет данных, это свойство определяет, будет ли FlowFile отправлен в соответствующую связь |
Взаимосвязи
- failure: Если FlowFile не может быть преобразован из настроенного входного формата в настроенный выходной формат, неизменный FlowFile будет отправлен в эту связь
- success: FlowFiles, которые были успешно преобразованы, будут отправлены в эту связь