org.apache.tez.runtime.api

Class AbstractLogicalIOProcessor

java.lang.Object

org.apache.tez.runtime.api.AbstractLogicalIOProcessor

All Implemented Interfaces:

LogicalIOProcessor, LogicalIOProcessorFrameworkInterface, Processor, ProcessorFrameworkInterface

@InterfaceAudience.Public
public abstract class AbstractLogicalIOProcessor
extends Object
implements LogicalIOProcessor, LogicalIOProcessorFrameworkInterface

Abstract representation of the interface LogicalIOProcessor. Implements the base logic of some methods into this class and is expected to be the base class that is derived to implement the user Processor

Constructor Summary

Constructors

Constructor and Description
AbstractLogicalIOProcessor(ProcessorContext context) Constructor an instance of the LogicalProcessor.

Method Summary

Modifier and Type	Method and Description
void	abort() Indicates Processor to abort.
ProcessorContext	getContext()
abstract void	initialize() Initializes the Processor

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.tez.runtime.api.LogicalIOProcessorFrameworkInterface

run

Methods inherited from interface org.apache.tez.runtime.api.ProcessorFrameworkInterface

close, handleEvents

Constructor Detail

AbstractLogicalIOProcessor

public AbstractLogicalIOProcessor(ProcessorContext context)

Constructor an instance of the LogicalProcessor. Classes extending this one to create a LogicalProcessor, must provide the same constructor so that Tez can create an instance of the class at runtime.

Parameters:

context - the ProcessorContext which provides the Processor with context information within the running task.

Method Detail

initialize

public abstract void initialize()
                         throws Exception

Description copied from interface: ProcessorFrameworkInterface

Initializes the Processor

Specified by:

initialize in interface ProcessorFrameworkInterface

Throws:

IOException - if an error occurs

Exception

getContext

public final ProcessorContext getContext()

abort

public void abort()

Description copied from interface: ProcessorFrameworkInterface

Indicates Processor to abort. Cleanup can be done.

Specified by:

abort in interface ProcessorFrameworkInterface