I have a complex flow where I created 3 attributes, [name, date, json_content] extracted from other flow file data that need to go into a database. How can I take these 3 attributes convert them to a new flow file with those columns? The schema I will use has those names.
Schema:
{
"type": "record",
"name": "mytable",
"fields": [
{"name": "name","type": [ "string" ]},
{"name": "date","type": "type" : [ "null", { "type" : "long", "logicalType" : "timestamp-millis" } ], "default" : null }
},
{"name": "json_content","type": [ "string" ]
}]
}