I am trying to replace value in the query that is fetched from another processor in nifi, How can I achieve this or what is the best way to do it? The processor details are as follows,
- Execute SQL Processor ->
SELECT Rno FROM sampleDB WHERE operation = 1;
- SplitAvro Processor
- Convert Avro to Json -> Here I get following JSON
{'Rno':'121'}
- Execute SQL Processor ->
DELETE FROM NewDB WHERE Rno = X
(here X should be replaced by the Rno received from previous processor that is '121')
How to achieve step 4 what processors should be used in addition to the above ones?