JoinEnrichment
Описание
Объединяет записи из двух различных FlowFiles, где один FlowFile, 'original', содержит произвольные записи, а второй FlowFile, 'enrichment', содержит дополнительные данные, которые должны быть использованы для обогащения первого.
Теги
fork, join, enrichment, record, sql, wrap, recordpath, merge, combine, streams
Свойства
| Название | Описание |
|---|---|
| Original Record Reader | Средство чтения записей для чтения «исходного» FlowFile |
| Enrichment Record Reader | Средство чтения записей для чтения «обогащенного» FlowFile |
| Record Writer | Записывающее устройство для записи результатов. Если записывающее устройство настроено на наследование схемы от записи, то схема, которую оно унаследует, будет результатом объединения «исходной» схемы записи и «обогащённой» схемы записи. |
| Join Strategy | Указывает, как объединить два файла потока в один файл потока. |
| SQL | Оператор SQL SELECT для оценки. Можно использовать язык выражений, но это может привести к снижению производительности. Поскольку этот процессор одновременно работает с двумя файлами Flow, важно понимать, как будут использоваться атрибуты. Если в обоих файлах Flow есть атрибут с одинаковым именем, но разными значениями, язык выражений будет использовать значение, указанное в файле Flow с «обогащением». Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Join Strategy] Property has a value of "SQL". |
| Default Decimal Precision | Когда значение DECIMAL/NUMBER записывается как логический тип Avro «decimal», требуется определённая «точность», обозначающая количество доступных цифр. Как правило, точн ость определяется типом данных столбца или настройками базы данных по умолчанию. Однако некоторые базы данных могут возвращать неопределённую точность (0). «Десятичная точность по умолчанию» используется при записи чисел с неопределённой точностью. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Join Strategy] Property has a value of "SQL". |
| Default Decimal Scale | Когда значение DECIMAL/NUMBER записывается как логический тип Avro «десятичный», требуется определённая «шкала», обозначающая количество доступных десятичных цифр. Как правило, шкала определяется типом данных столбца или настройками базы данных по умолчанию. Однако при возврате неопределённой точности (0) шкала также может быть неопределённой в некоторых базах данных. «Десятичная шкала по умолчанию» используется при записи таких неопределённых чисел. Если значение содержит больше десятичных знаков, чем указано в масштабе, то значение будет округлено в большую сторону, например, 1,53 станет 2 при масштабе 0 и 1,5 при масштабе 1. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Join Strategy] Property has a value of "SQL". |
| Insertion Record Path | Указывает, в какое поле «исходной» записи следует вставить поля «обогащённой» записи. Обратите внимание, что если RecordPath не указывает на какое-либо существующее поле в исходной записи, обогащение не будет вставлено. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Join Strategy] Property has a value of "Insert Enrichment Fields". |
| Maximum number of Bins | Указывает максимальное количество корзин, которые могут одновременно храниться в памяти. |
| Timeout | Указывает максимальное время ожидания второго файла потока после того, как первый файл поступит в процессор, после чего первый файл потока будет перенаправлен в отношение «тайм-аут». |
Взаимосвязи
- timeout: Если один из входящих файлов потока (т. е. «исходный» файл потока или «обогащенный» файл потока) поступает в этот процессор, но другой файл не поступает в течение нас троенного периода ожидания, то поступивший файл потока направляется в это отношение.
- joined: Полученный файл потока с записями, объединенными из исходного файла потока и файла потока с обогащением, будет направлен в это отношение.
- failure: Если «исходный» и «обогащенный» файлы Flow поступают в процессор, но при объединении записей возникает ошибка, оба этих файла Flow будут направлены в эту связь.
- original: Оба входящих файла потока («исходный» и «с обогащением») будут направлены в это отношение. То есть это «исходная» версия обоих этих файлов потока.