org.apache.flink.runtime.operators

Interface TaskContext<S,OT>

Type Parameters:

S - The UDF type.

OT - The produced data type.

All Known Implementing Classes:

AbstractIterativeTask, BatchTask, IterationHeadTask, IterationIntermediateTask, IterationTailTask

public interface TaskContext<S,OT>

The task context gives a driver (e.g., MapDriver, or JoinDriver) access to the runtime components and configuration that they can use to fulfil their task.

See Also:

Driver

Method Summary

Modifier and Type	Method and Description
String	formatLogString(String message)
AbstractInvokable	getContainingTask()
<X> TypeComparator<X>	getDriverComparator(int index)
ExecutionConfig	getExecutionConfig()
<X> MutableObjectIterator<X>	getInput(int index)
<X> TypeSerializerFactory<X>	getInputSerializer(int index)
IOManager	getIOManager()
MemoryManager	getMemoryManager()
OperatorMetricGroup	getMetricGroup()
Collector<OT>	getOutputCollector()
S	getStub()
TaskConfig	getTaskConfig()
TaskManagerRuntimeInfo	getTaskManagerInfo()
ClassLoader	getUserCodeClassLoader()

Method Detail

getTaskConfig

TaskConfig getTaskConfig()

getTaskManagerInfo

TaskManagerRuntimeInfo getTaskManagerInfo()

getUserCodeClassLoader

ClassLoader getUserCodeClassLoader()

getMemoryManager

MemoryManager getMemoryManager()

getIOManager

IOManager getIOManager()

getInput

<X> MutableObjectIterator<X> getInput(int index)

getInputSerializer

<X> TypeSerializerFactory<X> getInputSerializer(int index)

getDriverComparator

<X> TypeComparator<X> getDriverComparator(int index)

getStub

S getStub()

getExecutionConfig

ExecutionConfig getExecutionConfig()

getOutputCollector

Collector<OT> getOutputCollector()

getContainingTask

AbstractInvokable getContainingTask()

formatLogString

String formatLogString(String message)

getMetricGroup

OperatorMetricGroup getMetricGroup()