Support Questions
Find answers, ask questions, and share your expertise

How to delete the records based on the primary key in target table using NiFI?

How to delete the records based on the primary key in target table using NiFI?

Hi Team,

I want to implement the following query using NiFi processor without using sql queries? For that what are the processor do i need to use?

delete from table_B where id_1 in( select id_1 from table_A where flag = ‘N’)

Note: Both the columns are different except few matching columns Ex table_A has 10 columns and table_B has 20 columns. and it's streaming process.

Thanks.