Nifi. QueryDatabaseTable. Использование значения MaxValue (состояние процессора) внутри пользовательского запроса - PullRequest
0 голосов
/ 03 февраля 2020

Я использую QueryDatabaseTable для инкрементального захвата данных из реляционного источника. Мой запрос настраивается, и таблица, которая содержит столбец для фильтра, группируется и сортируется во время выполнения запроса. Но фильтр состояния накладывается после всех операций группировки, сортировки и объединения. Могу ли я использовать значение состояния внутри пользовательского запроса, например, переменные потока? Это не оптимально - фильтровать данные после тяжелых операций. Спасибо за вашу помощь!

A.

...