Member since
08-20-2020
5
Posts
0
Kudos Received
0
Solutions
09-10-2020
06:11 AM
@stevenmatison Just a small correction to the description, The columns in my CSV will be adding up every year. No columns will be removed from my CSV If in this year I have 100 columns next year it will be 110, so every year 10 new columns will get added . Basically I have 10 columns with the suffix of year, repeated for different years Once I validate them using a schema I will be applying transformation on these columns to make 110 columns into 20 columns according to my database. Also I got what you are saying but I want to find a dynamic way to validate the CSV . If you can help me with some mock flow which is similar to my challenge it will be of great help(Also preferably I want to achieve without using custom processors or script)
... View more
09-10-2020
05:25 AM
I have a scenario where the columns in a CSV are consistently changing, I want to validate this CSV irrespective of the changes Currently I am validating using a static schema, by placing a static schema in Schema Text property of Validate Record processor. But everytime there is a change in file format(a new column is added or removed) I have to update the schema in Schema text property of processor. Is there a way I can make this dynamic ? Currently I am using NIFI 1.11.4(I couldnt find InferSchema processor or JSON to Avro converter)
... View more
Labels:
- Labels:
-
NiFi Registry