Created on
10-30-2019
12:52 PM
- last edited on
10-31-2019
03:02 AM
by
VidyaSargur
I'm curious about how a flow would look.
So I have written a spark program to determine missing data between my source(Oracle,keeps deleting files) and my destination(IBM DB2).
I bring in the data into my nifi flow with GETHDFS and it brings in the primary keys of the data that is missing, I want to then use these primary keys to run a process that will delete them from destination(IBM Db2).
Any help would be appreciated.