org.apache.tez.mapreduce.processor.reduce

Class ReduceProcessor

java.lang.Object

org.apache.tez.runtime.api.AbstractLogicalIOProcessor

org.apache.tez.mapreduce.processor.MRTask

org.apache.tez.mapreduce.processor.reduce.ReduceProcessor

All Implemented Interfaces:

org.apache.tez.runtime.api.LogicalIOProcessor, org.apache.tez.runtime.api.LogicalIOProcessorFrameworkInterface, org.apache.tez.runtime.api.Processor, org.apache.tez.runtime.api.ProcessorFrameworkInterface

@InterfaceAudience.Private
public class ReduceProcessor
extends MRTask

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,org.apache.tez.runtime.api.LogicalInput>	inputs
protected Map<String,org.apache.tez.runtime.api.LogicalOutput>	outputs

Fields inherited from class org.apache.tez.mapreduce.processor.MRTask

committer, jobConf, jobContext, jobTokenSecret, mrReporter, processorContext, progress, taskAttemptContext, taskAttemptId, useNewApi

Constructor Summary

Constructors

Constructor and Description
ReduceProcessor(org.apache.tez.runtime.api.ProcessorContext processorContext)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	handleEvents(List<org.apache.tez.runtime.api.Event> processorEvents)
void	localizeConfiguration(org.apache.hadoop.mapred.JobConf jobConf)
void	run(Map<String,org.apache.tez.runtime.api.LogicalInput> _inputs, Map<String,org.apache.tez.runtime.api.LogicalOutput> _outputs)

Methods inherited from class org.apache.tez.mapreduce.processor.MRTask

createReduceContext, done, getConf, getCounters, getFsStatistics, getJobContext, getMRReporter, getOutputName, getTaskAttemptContext, getTaskAttemptId, getUmbilical, initialize, initTask, normalizeStatus, setConf, statusUpdate, taskCleanup, waitBeforeCompletion

Methods inherited from class org.apache.tez.runtime.api.AbstractLogicalIOProcessor

abort, getContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inputs

protected Map<String,org.apache.tez.runtime.api.LogicalInput> inputs

outputs

protected Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs

Constructor Detail

ReduceProcessor

public ReduceProcessor(org.apache.tez.runtime.api.ProcessorContext processorContext)

Method Detail

handleEvents

public void handleEvents(List<org.apache.tez.runtime.api.Event> processorEvents)

close

public void close()
           throws IOException

Throws:

IOException

run

public void run(Map<String,org.apache.tez.runtime.api.LogicalInput> _inputs,
       Map<String,org.apache.tez.runtime.api.LogicalOutput> _outputs)
         throws Exception

Throws:

Exception

localizeConfiguration

public void localizeConfiguration(org.apache.hadoop.mapred.JobConf jobConf)
                           throws IOException,
                                  InterruptedException

Overrides:

localizeConfiguration in class MRTask

Throws:

IOException

InterruptedException