I have resolved this problem statement with the below approach 1. Count the number of input_file_count (fragments.count gives me the result) 2. Prepare transnational table with the scheam (primary_key_id , processesed_file_cnt). 3. Add inital record at the beginning of the NiFi pipeline using INSERT INTO command. e.g. INSERT INTO <tableName> values(23,0) 4. Keep on update the processed_file_cnt using update query by one for each batch 5. select processed_file_cnt column and compare it with input_file_count. 6. If matched , then kick start next flow else terminate Unmatched relationship to same RouteOnAttribute processor.
... View more
