org.apache.tez.runtime.api

Interface LogicalIOProcessorFrameworkInterface

All Superinterfaces:

ProcessorFrameworkInterface

All Known Implementing Classes:

AbstractLogicalIOProcessor

@InterfaceAudience.Public
public interface LogicalIOProcessorFrameworkInterface
extends ProcessorFrameworkInterface

Represents a processor framework interface which consumes LogicalInputs and produces LogicalOutputs. Users are expected to implements AbstractLogicalIOProcessor

Method Summary

Methods

Modifier and Type	Method and Description
void	run(Map<String,LogicalInput> inputs, Map<String,LogicalOutput> outputs) Runs the Processor

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

abort, close, handleEvents, initialize

Method Detail

run

void run(Map<String,LogicalInput> inputs,
       Map<String,LogicalOutput> outputs)
         throws Exception

Runs the Processor

Parameters:

inputs - a map of the source vertex name to LogicalInput - one per incoming edge.

outputs - a map of the destination vertex name to LogicalOutput - one per outgoing edge

Throws:

Exception - TODO