Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

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.

Don't have an account?
Coming from Hortonworks? Activate your account here