org.apache.tez.runtime.api

Interface OutputContext

All Superinterfaces:

TaskContext

@InterfaceAudience.Public
public interface OutputContext
extends TaskContext

Context handle for the Output to initialize itself. This interface is not supposed to be implemented by users

Method Summary

Modifier and Type	Method and Description
String	getDestinationVertexName() Get the Vertex Name of the Destination that is the recipient of this Output's data
int	getOutputIndex() Get the index of the output in the set of all outputs for the task.
OutputStatisticsReporter	getStatisticsReporter() Get an OutputStatisticsReporter for this Output that can be used to report statistics like data size

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

fatalError, getApplicationId, getCounters, getDAGAttemptNumber, getDagIdentifier, getDAGName, getExecutionContext, getObjectRegistry, getServiceConsumerMetaData, getServiceProviderMetaData, getTaskAttemptNumber, getTaskIndex, getTaskVertexIndex, getTaskVertexName, getTotalMemoryAvailableToTask, getUniqueIdentifier, getUserPayload, getVertexParallelism, getWorkDirs, notifyProgress, reportFailure, requestInitialMemory, sendEvents

Method Detail

getDestinationVertexName

String getDestinationVertexName()

Get the Vertex Name of the Destination that is the recipient of this Output's data

Returns:

Name of the Destination Vertex

getOutputIndex

int getOutputIndex()

Get the index of the output in the set of all outputs for the task. The index will be consistent and valid only among the tasks of this vertex.

Returns:

index

getStatisticsReporter

OutputStatisticsReporter getStatisticsReporter()

Get an OutputStatisticsReporter for this Output that can be used to report statistics like data size

Returns:

OutputStatisticsReporter