APACHE Обходной путь поиска NIFI - PullRequest
0 голосов
/ 07 августа 2020

Конечная цель: уметь идентифицировать потоковый файл как вставку или обновление

Идея: ввести запись из источника, сравнить PK в потоковом файле с этим листом, файлом, таблицей данных запроса из целевая БД, которая извлекает все пакеты для этого представления. Затем я могу направить этот файл как вставку или обновление. Это сделано для повышения скорости.

Вопрос для стека: есть ли способ сравнить PK моего текущего потокового файла с PK всех сгенерированных значений (я бы генерировал этот потоковый файл, как каждые 6, 12,18 или 24 часа)

...