[
https://issues.apache.org/jira/browse/MAPREDUCE-372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12752452#action_12752452
]
Jothi Padmanabhan commented on MAPREDUCE-372:
---------------------------------------------
Just to make it easier, here is the pseudo copy constructor that we needed to
add
{code}
/**
* A pseudo copy constructor. Set the record writer and configuration values
* to the passed arguments and the rest of the fields from the other
* context object. Used by Chain Reducer
* @param context
* @param output
* @param conf
* @throws InterruptedException
* @throws IOException
*/
public ReduceContext(ReduceContext<KEYIN, VALUEIN, ?, ?> context,
RecordWriter<KEYOUT,VALUEOUT> output,
Configuration conf)
throws InterruptedException, IOException{
super(conf, context.taskid, output, context.getOutputCommitter(),
context.getReporter());
this.input = context.input;
this.inputCounter = context.inputCounter;
this.comparator = context.comparator;
this.serializationFactory = context.serializationFactory;
this.keyDeserializer = context.keyDeserializer;
this.valueDeserializer = context.valueDeserializer;
this.keyClass = context.keyClass;
this.valueClass = context.valueClass;
this.conf = conf;
this.taskid = context.taskid;
this.hasMore = context.hasMore;
this.buffer = context.buffer;
}
{code}
> Change org.apache.hadoop.mapred.lib.ChainMapper/Reducer to use new api.
> -----------------------------------------------------------------------
>
> Key: MAPREDUCE-372
> URL: https://issues.apache.org/jira/browse/MAPREDUCE-372
> Project: Hadoop Map/Reduce
> Issue Type: Sub-task
> Reporter: Amareshwari Sriramadasu
> Assignee: Amareshwari Sriramadasu
> Fix For: 0.21.0
>
> Attachments: mapred-372.patch, patch-372-1.txt, patch-372.txt
>
>
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
