你好,我试图使数据流通过Nifi这是listFile-
但是,我想以某种方式暂停fetchFile处理器或保留从本地服务器接收到的流文件,直到前一个流文件完全通过下游,在putKudu处理器之后,然后一个接一个地释放下一个流文件。
我查看了等待和通知处理器,但找不到通知队列中要释放的下一个流的方法。
感谢任何帮助。
我认为您可以通过将FetchFile之后的所有处理器放在具有输入端口的进程组中来实现您想要的。将FetchFile连接到进程组。然后您将Process Group本身配置为具有1的Flowfile并发。
这应该会导致进程组内的输入端口在prevoous完成时仅接受一个文件。