Hi,

is there any chance to write custom attributes into AVRO file schema?


A = load 'data' using PigStorage(',') AS (b1:int,b2:int,b3:bytearray);

STORE A INTO 'testOutput'
USING org.apache.pig.piggybank.storage.avro.AvroStorage(
'schema',
' {"type":"record","name":"X",
"fields":[{"name":"b1","type":"int"},
{"name":"b2","type":"int"},{"name":"b3","type":"bytes",

*            "DataProfile": "A",            "ValidityDate": "2015-01-01"*
}]}');


Thank you

Reply via email to