Исполнительский комплекс Join in Nifi - PullRequest
Новая
       7

Исполнительский комплекс Join in Nifi

0 голосов
/ 07 ноября 2018

Я очень новичок в Nifi и пытаюсь выполнить SQL против SQL-сервера, который объединяет несколько таблиц, а также выбирать атрибуты из каждой. Как мы можем выполнить это в Нифи. Я вижу "Сгенерировать выборку таблицы", которая позволяет мне упомянуть "Имя таблицы" и ее "Куда пункт". Не уверен, как нам выполнить сложное объединение, если задействовано несколько таблиц.

ПРИМЕР- 

Select 
a.col1,
a.col2,
b.col3,
b.col4,
c.col5,
c.col6
from a left outer join b
on a.colx=b.colx
inner join c
on a.coly = c.coly
where exists (some condition etc)

Спасибо, Сиддхартха

1 Ответ

0 голосов
/ 07 ноября 2018

Используйте ExecuteSQL/ExecuteSQLRecord(NiFi-1.8+) процессор и сохраняйте свой запрос в SQL select query свойстве.

Настройка / Включение пул соединений dbcp .

Помните ExecuteSQL Процессор не сохраняет состояние :

  • Так что, если вы хотите запускать процессор постепенно, вам нужно сохранять состояние в NiFi (или) извне, затем каждый раз извлекать значение состояния и выполнять ваш запрос.

  • См. эту ссылку для более подробной информации о сохранении / извлечении состояния с использованием NiFi.

...