Member since
09-05-2024
7
Posts
4
Kudos Received
0
Solutions
12-03-2024
05:18 AM
1 Kudo
Hi @SAMSAL , Thanks for the link you provided in your answer, it helped me understand the use of forkEnrichement, while I was trying to figure out the use of joinEnrichement. In my case I am first reading a column from a database table, then I am reading a column from a csv file, I have to join the db column with the csv column in a certain way to get my desired result. So, what is done here is, the data from db is provided to fork enrichment, it makes two copies of it, one is called 'original' and the other is called 'enrichment'. Though I am not performing anything on the enrichment flow file, rather I am overwriting it with my csv data, because that's what I need to do later in join enrichment i.e. to join the data from db to csv data. I have achieved the same using another way previously, by adding a property to each set of data i.e. db one and csv one to identify them separately while joining them, then I am merging them and then using queryRecord to finally join them and extract the result set I need. However, if you have suggestions to achieve this in a better way, do share with us, thanks.
... View more
10-10-2024
06:55 AM
1 Kudo
I set the Translate Field Names to false, it started working, before this it was converting the primary key field to upper case, removing the underscore, so when I run the putSQL, it was throwing error, working fine now, thanks to your answer!
... View more