S
- The UDF type.OT
- The produced data type.public interface TaskContext<S,OT>
MapDriver
, or JoinDriver
) access to
the runtime components and configuration that they can use to fulfil their task.Driver
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() |
TaskConfig getTaskConfig()
TaskManagerRuntimeInfo getTaskManagerInfo()
ClassLoader getUserCodeClassLoader()
MemoryManager getMemoryManager()
IOManager getIOManager()
<X> MutableObjectIterator<X> getInput(int index)
<X> TypeSerializerFactory<X> getInputSerializer(int index)
<X> TypeComparator<X> getDriverComparator(int index)
S getStub()
ExecutionConfig getExecutionConfig()
AbstractInvokable getContainingTask()
OperatorMetricGroup getMetricGroup()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.