Агрегирование данных в Apache Nifi

Question

Я использую Apache nifi для обработки данных из разных ресурсов, и у меня есть независимые конвейеры, созданные для каждого потока данных. Я хочу объединить эти данные для дальнейшей обработки. Есть ли способ собрать данные и записать их в один файл. Данные присутствуют в виде атрибутов flowfiles в Nifi.

Answer 1

Вы должны использовать процессор MergeContent, который принимает значения конфигурации для размера партии min/max и т. Д. И объединяет несколько файловых файлов в один файл потока в соответствии с предоставленной стратегией слияния.