Перейти к основному содержимому

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, которые были успешно преобразованы, будут отправлены в эту связь