Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
0.9.1
-
any
-
The hive code change should take care of existing code base, so it is backward compatible.
-
extend RecordWriter RecordReader to pass in counter
Description
We would like to generate some custom statistics and report back to map/reduce later wen implement the
FileSinkOperator.RecordWriter interface. However, the current interface design doesn't allow us to get the map reduce reporter object. Please extend the current FileSinkOperator.RecordWriter interface so that it's close() method passes in a map reduce reporter object.
For the same reason, please also extend the RecordReader interface too to include a reporter object so that users can passes in custom map reduce counters.