Yes that's what I am looking for. Question is - How do I update the
GenericRecord, I want to update user_id field with some new random long
number.?
Can you provide an example how can I update GenericRecord and then
serialize it to a new Byte Array?
On Mon, Jan 12, 2015 at 4:34 PM, Joey
I'm not sure I understand the question. You can certainly deserialize
the byte array back into a GenericRecord. You can then update that
GenericRecord and serialize that to a new byte array.
Is that what you're looking for?
-Joey
On Mon, Jan 12, 2015 at 3:42 PM, Check Peck
Thanks Deepak,
I tried using below but that also not helping in changing output file name…
In Job file
MultipleOutputs.addNamedOutput(job, clean, AvroKeyOutputFormat.class,
Measurement.class , NullWritable.class);
In Reducer
Setup:
MultipleOutputsMeasurement, NullWritable mos;
Please ignore last one…
Thanks Deepak,
I tried using below but that also not helping in changing output file name…
In Job file
MultipleOutputs.addNamedOutput(job, clean, AvroKeyOutputFormat.class,
Measurement.class , NullWritable.class);
In Reducer
Setup:
MultipleOutputsMeasurement,
