Добавочная загрузка из нескольких таблиц для запросов на соединение в Nifi
Для инкрементальной загрузки мы будем использовать процессор QueryDatabaseTable, который постепенно извлекает данные из одной таблицы. Для написания sql-запроса, который извлекает данные из нескольких таблиц, мы используем процессор ExecuteSQL.
Как мы можем извлечь дополнительную нагрузку для запроса соединения ??
1 ответ
Если я понимаю, что вы пытаетесь сделать, в NiFi это шаблон поиска, поэтому вы, вероятно, будете использовать LookupRecord с DatabaseRecordLookupService. Каждый из них будет «присоединяться» к таблице добавочной загрузки со строками из таблицы, указанной службой DatabaseRecordLookupService. Для нескольких соединений у вас будет LookupRecord с соответствующим DatabaseRecordLookupService для каждого из них.