NIFI:如何等待所有先前的处理器完成执行然后只做一次?

NIFI: How to wait for all the previous processors to finish execution and then do something just once?

我在 NIFI 中有一个场景,我在许多不同的处理器中执行复杂的任务。我想在此流程末尾再添加一个处理器。这个处理器想要等待所有处理器完成然后执行它(只执行一次!)。

如何实现?

您可能需要查看 Wait/Notify 处理器来执行此类协调...

https://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/

https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.4.0/org.apache.nifi.processors.standard.Wait/index.html

https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.4.0/org.apache.nifi.processors.standard.Notify/index.html