0

我正在使用GenerateTableFetch包含table_name导入数据的传入流文件。我已经手动使用表的列Additional WHERE clause来处理增量更新。updated_at

问题是当构建查询没有要导入的数据时,它只是删除流文件。对于这种情况,除了成功和失败之外,它应该有一个单独的关系,这样如果必须为这种情况做些什么,我可以自己处理。

目前,在工作流程开始时,我正在使用Wait已投入流程的表格数量并跟踪它们何时完成以使用Notify. 但是对于被丢弃的表GenerateTableFetch,它只是继续等待。

有什么办法处理这个吗?

4

1 回答 1

0

这确实是添加到 GenerateTableFetch 的一个很好的改进,可能是“在零结果上输出空流文件”或其他东西的可选属性。我编写了 NIFI-5604来涵盖这一改进。将此与 NIFI-5601 结合使用,您可以进行下游路由(例如,如果 fragment.count = 0)。

于 2018-09-18T15:01:58.537 回答