NiFi Как запросить репозиторий контента из NiFi Flow

Question

У меня есть случай, когда мне нужно использовать FlowFile из другого потока.

Как я знаю, все потоковые файлы сохраняются в репозитории контента.

Так, например, мой первый поток читает данные из БД, выполняет некоторые преобразования и вставляет их в Hive.

Мой второй поток должен получить эти преобразованные файлы потоков и поместить их в другое место или выполнить некоторую фильтрацию и т. Д.

Как я могу получить эти потоковые файлы из репозитория контента в потоке NiFi?

Answer 1

Вы ошибаетесь, содержимое потоковых файлов сохраняется в репозитории содержимого. Вам не нужно запрашивать репозиторий контента, чтобы использовать эти FlowFiles. Я предполагаю, что вы используете PutHiveQL, поэтому просто используйте отношение success для вашего следующего потока.

Пример: ExecuteSQL -> (успех) Transform Process Group -> (вывод) PutHiveQL -> (успех) -> Следующий поток

Примерно так: