org.apache.tez.mapreduce.processor.map
Class MapProcessor

java.lang.Object
  org.apache.tez.mapreduce.processor.MRTask
      org.apache.tez.mapreduce.processor.map.MapProcessor

All Implemented Interfaces:

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

public class MapProcessor
extends MRTask
implements org.apache.tez.runtime.api.LogicalIOProcessor

Field Summary

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

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

Constructor Summary

MapProcessor()

Method Summary

void	close()
void	handleEvents(List<org.apache.tez.runtime.api.Event> processorEvents)
void	initialize(org.apache.tez.runtime.api.TezProcessorContext processorContext)
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, getState, getTaskAttemptContext, getTaskAttemptId, getUmbilical, initTask, normalizeStatus, setConf, setState, statusUpdate, taskCleanup, waitBeforeCompletion

Methods inherited from class java.lang.Object

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

Constructor Detail

MapProcessor

public MapProcessor()

Method Detail

initialize

public void initialize(org.apache.tez.runtime.api.TezProcessorContext processorContext)
                throws IOException

Specified by:

initialize in interface org.apache.tez.runtime.api.Processor

Overrides:

initialize in class MRTask

Throws:

IOException

handleEvents

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

Specified by:

handleEvents in interface org.apache.tez.runtime.api.Processor

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.tez.runtime.api.Processor

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

Specified by:

run in interface org.apache.tez.runtime.api.LogicalIOProcessor

Throws:

Exception

localizeConfiguration

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

Overrides:

localizeConfiguration in class MRTask

Throws:

IOException

InterruptedException