How to store Avro format in HDFS using PIG?

Question

After processing input data, I've a JAVA object. I've created avro schema for storing the object in avro file. I'm stuck at writing the object using schema into HDFS. Can anyone walk me through the process of writing the object using PIG script & corresponding UDF?

Answer 1

I suppose you are using an UDF if you use Java.

So you have just to return the result of your UDF as a pig Tuple.

Then you get a relation with your data ready to store.

Finally You can use the STORE command using AvroStorage.