Hi folks,
Is possible to declare an Avro schema for a ConvertRecord processor to
handle multi-record file ie a file where each line may be a different avro
record?
Something like this:
{
"type" : "record",
"namespace" : "com.acme",
"name" : "OrderFile",
"fields" : [
{
"type" : "record",
"namespace" : "com.acme",
"name" : "HeaderRecord",
"fields" : [
{"name":"PNSTORE", "type": "string"},
{"name":"STORENAME", "type": "string"},
{"name":"EXTRACTIONDATE", "type": "string"}
]
},
{
"type" : "record",
"namespace" : "com.acme",
"name" : "OrderRecord",
"fields" : [
{ "name": "SALESMAN", "type": "string" },
{ "name": "ORDER_NUMBER", "type": "string" },
{ "name": "DUE_DATE", "type": "string" },
{ "name": "ORDER_AMOUNT", "type": "long" }
]
},
{
"type" : "record",
"namespace" : "com.acme",
"name" : "TrailerRecord",
"fields" : [
{"name":"TOTAL_RECORDS", "type": "long"},
{"name":"TOTAL_AMOUNT", "type": "long"}
]
}
]
}
Thanks in advance,
Eric