Nifi中联接查询的多个表的增量加载

Question

对于增量加载，我们将使用QueryDatabaseTable处理器，它从一个表中增量提取数据。为了编写从多个表中提取数据的sql查询，我们使用了ExecuteSQL处理器。

我们如何提取联接查询的增量负载？？

Answer 1

如果我理解你想做什么，在NiFi中，这是一种查找模式，所以你可能会将LookupRecord与DatabaseRecordLookupService一起使用。每一个都会"；加入"；增量加载表，其中包含DatabaseRecordLookupService指定的表中的行。对于多个联接，您会有一个LookupRecord，每个联接都有相应的DatabaseRecordLookupService。