Hi, I am working on building a flow in NiFi that involve cloning a file to 2 or more processing flows, and then wait (on some processor) for all the parallel flows to finish (in parallel) and execute a another flow.
Is there any processor in Nifi which can do this out of the box i.e. wait for N file in input queue and then start its processing and timeout if expected N files didn't arrive in some time T? If not, what's a good way of achieving this. I have such a flow implemented in Akka, and want to migrate it to NiFi. I am using NiFi 1.3 Thanks, Manish Gupta Senior Specialist Platform | AI & Data Engineering Practice ________________________________ "Oxygen", Tower C, Ground - 3rd floor, Plot No. 7, Sector 144 Expressway, Noida, UP, India Mobile: +91 981 059 1361 Office: +91 (120) 479 5000 Ext : 75398 Email: mgupt...@sapient.com<mailto:mgupt...@sapient.com> sapientconsulting.com<https://www.sapientconsulting.com/>
