JoltTransformRecord
Описание
Применяет спецификацию JOLT к каждой записи в полезной нагрузке файла потока. Создается новый файл потока с преобразованным содержимым, который направляется в отношение «success». Если преобразование завершится неудачно, оригинальный файл потока будет направлен в отношение «failure».
Теги
record, jolt, transform, shiftr, chainr, defaultr, removr, cardinality, sort
Свойства
| Название | Описание |
|---|---|
| Jolt Transform | Указывает преобразование Jolt, которое следует использовать с предоставленной спецификацией. |
| Jolt Specification | Спецификация Jolt для преобразования данных JSON. Значение этого свойства может быть текстом спецификации Jolt или путём к файлу, содержащему спецификацию Jolt. Необходимо задать «Спецификацию Jolt», иначе значение будет проигнорировано, если выбрано преобразование сортировки Jolt.This property requires exactly one resource to be provided. That resource may be any of the following types: file, text. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Custom Transformation Class Name | Полное имя класса для пользовательского преобразования Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Jolt Transform] Property has a value of "Custom". |
| Custom Module Directory | Список путей к файлам и/или каталогам, разделённым запятыми, которые содержат модули, содержащие пользовательские преобразования (которые не включены в путь к классам NiFi).This property expects a comma-separated list of resources. Each of the resources may be of any of the following types: directory, file. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)This Property is only considered if the [Jolt Transform] Property has a value of "Custom". |
| Transform Cache Size | Компиляция Jolt Transform может быть довольно затратной. В идеале это должно быть сделано только один раз. Однако, если в преобразовании используется язык выражений, нам может потребоваться новое преобразование для каждого файла потока. Это значение определяет, сколько из этих преобразований мы кэшируем в памяти, чтобы избежать необходимости компилировать преобразование каждый раз. |
| Record Reader | Указывает службу контроллера для использования при синтаксическом анализе входящих данных и определении схемы данных. |
| Record Writer | Указывает службу контроллера, используемую для записи данных |
Взаимосвязи
- success: Потоковый файл с преобразованным содержимым будет перенаправлен в это отношение
- failure: Если обработка FlowFile по какой-либо причине не удалась (например, записи FlowFile не удалось проанализировать), они будут перенаправлены в эту связь.
- original: Исходный FlowFile, который был преобразован. Если обработка FlowFile не удалась, в эту связь ничего не будет отправлено.