org.apache.tez.mapreduce.processor

Class SimpleMRProcessor

java.lang.Object

org.apache.tez.runtime.api.AbstractLogicalIOProcessor

org.apache.tez.runtime.library.processor.SimpleProcessor

org.apache.tez.mapreduce.processor.SimpleMRProcessor

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.Public
@InterfaceStability.Evolving
public abstract class SimpleMRProcessor
extends org.apache.tez.runtime.library.processor.SimpleProcessor

A SimpleProcessor that provides Map Reduce specific post processing by calling commit (if needed) on all MROutputs connected to this Processor.

Field Summary

Fields inherited from class org.apache.tez.runtime.library.processor.SimpleProcessor

inputs, outputs

Constructor Summary

Constructors

Constructor and Description
SimpleMRProcessor(org.apache.tez.runtime.api.ProcessorContext context)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	postOp()

Methods inherited from class org.apache.tez.runtime.library.processor.SimpleProcessor

close, getInputs, getOutputs, handleEvents, initialize, preOp, run, run

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

Constructor Detail

SimpleMRProcessor

public SimpleMRProcessor(org.apache.tez.runtime.api.ProcessorContext context)

Method Detail

postOp

protected void postOp()
               throws Exception

Overrides:

postOp in class org.apache.tez.runtime.library.processor.SimpleProcessor

Throws:

Exception