Ограничение строк при получении записей с помощью таблицы QueryDatabase с использованием NiFi

Question

Я пытаюсь использовать процессор QueryDatabase с использованием Apache NiFi. Можно ли каким-либо образом ограничить записи следующим образом: «выбрать * из ограничения таблицы 100»

Любой другой процессор в NiFi, который поддерживает эту операцию?

Answer 1

Используйте ExecuteSQL процессор для этого случая.

• Настройка / включение пула соединений DBCP

• В SQL select query значение свойства сохраняет запрос выбора

  select * from table limit 100

Теперь процессор запускает сконфигурированный запрос sql select и выводит результаты запроса в виде потокового файла в AVRO формате