Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

Scheduling process groups in nifi

avatar
New Contributor

I have two process groups

 

P1 - Reads a csv file and inserts data into postgres table

 

P2 - Reads another csv file and updates data into the same postgres table based on a common key

 

I want P2 process group to start only when P1 process group has finished inserting all the rows of the csv file into the table

 

Example: I have a csv file with 100 lines so after P1 finishes inserting 100 rows to the db i want the P2 processor to start executing and update those rows with new data.

 

How can I achieve this in nifi?

 

1 REPLY 1

avatar

Hi,

You can do that in two ways:

1- Calling P2 from P1 using Output\Input Ports to connect process groups

2- Using Nifi API using nifi HttpInvoke Processor from P1 to control the run-state of the Initial Processor in P2.

Hope that help.

Thanks