org.apache.tez.runtime.library.processor

Class SimpleProcessor

java.lang.Object

org.apache.tez.runtime.api.AbstractLogicalIOProcessor

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

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

Direct Known Subclasses:

PreWarmProcessor

@InterfaceAudience.Public
@InterfaceStability.Evolving
public abstract class SimpleProcessor
extends org.apache.tez.runtime.api.AbstractLogicalIOProcessor

Implements an AbstractLogicalIOProcessor and provides empty implementations of most methods and handles input/output initialization. This can be used to implement simple Processors that dont need to do event handling etc.

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
protected org.apache.tez.common.ProgressHelper	progressHelper

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
Map<String,org.apache.tez.runtime.api.LogicalInput>	getInputs()
Map<String,org.apache.tez.runtime.api.LogicalOutput>	getOutputs()
void	handleEvents(List<org.apache.tez.runtime.api.Event> processorEvents)
void	initialize()
protected void	postOp() Called after run() is called and can be used to do post-processing like committing output etc
protected void	preOp() Implements input/output initialization.
abstract void	run() Users must implement this method to provide the main application logic code
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.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

progressHelper

protected org.apache.tez.common.ProgressHelper progressHelper

Constructor Detail

SimpleProcessor

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

Method Detail

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

run

public abstract void run()
                  throws Exception

Users must implement this method to provide the main application logic code

Throws:

Exception

preOp

protected void preOp()
              throws Exception

Implements input/output initialization. Can be overriden to implement custom behavior. Called before run() is called.

Throws:

Exception

postOp

protected void postOp()
               throws Exception

Called after run() is called and can be used to do post-processing like committing output etc

Throws:

Exception

initialize

public void initialize()
                throws Exception

Specified by:

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

Specified by:

initialize in class org.apache.tez.runtime.api.AbstractLogicalIOProcessor

Throws:

Exception

handleEvents

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

close

public void close()
           throws Exception

Throws:

Exception

getInputs

public Map<String,org.apache.tez.runtime.api.LogicalInput> getInputs()

getOutputs

public Map<String,org.apache.tez.runtime.api.LogicalOutput> getOutputs()