Use Row as the Key/Value

[lambdai]

Possible Solution
Rewrite the Mapper/Reducer or upper task generator
As long as we set-up the schema before de-serializing the Row, we can use Row#read(in)
Maybe by rewrite the task generator
See http://avro.apache.org/docs/1.7.6/mr.html
AvroJob.setInputSchema(conf, User.getClassSchema());