Как передавать значения динамически от одного процессора к другому процессору с помощью apache nifi

Question

Я хочу передать один результат процессора в качестве входа в другой процессор с использованием apache NiFi.

Я собираю значения из mysql с помощью процессора ExecuteSQL. I хочу динамически передавать этот результат на SelectHiveQL Processor в apache nifi.

Answer 1

ExecuteSQL выводит результирующий набор как Avro. Если вы хотите обрабатывать каждую строку отдельно, вы можете использовать SplitAvro, затем ConvertAvroToJson, или ConvertAvroToJson, затем SplitJson. В этот момент вы можете использовать EvaluateJsonPath для извлечения значений в атрибуты (для использования с NiFi Expression Language), и в какой-то момент вам, скорее всего, понадобится ReplaceText, где вы установите содержимое файла потока в инструкцию HiveQL (для использования SelectHiveQL).