Uses of Class
org.apache.flink.runtime.operators.util.TaskConfig
-
Packages that use TaskConfig Package Description org.apache.flink.runtime.jobgraph org.apache.flink.runtime.operators org.apache.flink.runtime.operators.chaining org.apache.flink.runtime.operators.util -
-
Uses of TaskConfig in org.apache.flink.runtime.jobgraph
Methods in org.apache.flink.runtime.jobgraph with parameters of type TaskConfig Modifier and Type Method Description void
InputOutputFormatContainer. write(TaskConfig config)
Constructors in org.apache.flink.runtime.jobgraph with parameters of type TaskConfig Constructor Description InputOutputFormatContainer(TaskConfig config, ClassLoader classLoader)
-
Uses of TaskConfig in org.apache.flink.runtime.operators
Fields in org.apache.flink.runtime.operators declared as TaskConfig Modifier and Type Field Description protected TaskConfig
BatchTask. config
The task configuration with the setup parameters.Methods in org.apache.flink.runtime.operators that return TaskConfig Modifier and Type Method Description TaskConfig
BatchTask. getLastTasksConfig()
TaskConfig
BatchTask. getTaskConfig()
TaskConfig
TaskContext. getTaskConfig()
Methods in org.apache.flink.runtime.operators with parameters of type TaskConfig Modifier and Type Method Description static <T> Collector<T>
BatchTask. getOutputCollector(AbstractInvokable task, TaskConfig config, ClassLoader cl, List<RecordWriter<?>> eventualOutputs, int outputOffset, int numOutputs)
Creates theCollector
for the given task, as described by the given configuration.static <T> Collector<T>
BatchTask. initOutputs(AbstractInvokable containingTask, UserCodeClassLoader cl, TaskConfig config, List<ChainedDriver<?,?>> chainedTasksTarget, List<RecordWriter<?>> eventualOutputs, ExecutionConfig executionConfig, Map<String,Accumulator<?,?>> accumulatorMap)
Creates a writer for each output.static <T> T
BatchTask. instantiateUserCode(TaskConfig config, ClassLoader cl, Class<? super T> superClass)
Instantiates a user code class from is definition in the task configuration. -
Uses of TaskConfig in org.apache.flink.runtime.operators.chaining
Fields in org.apache.flink.runtime.operators.chaining declared as TaskConfig Modifier and Type Field Description protected TaskConfig
ChainedDriver. config
Methods in org.apache.flink.runtime.operators.chaining that return TaskConfig Modifier and Type Method Description TaskConfig
ChainedDriver. getTaskConfig()
Methods in org.apache.flink.runtime.operators.chaining with parameters of type TaskConfig Modifier and Type Method Description void
ChainedDriver. setup(TaskConfig config, String taskName, Collector<OT> outputCollector, AbstractInvokable parent, UserCodeClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Accumulator<?,?>> accumulatorMap)
-
Uses of TaskConfig in org.apache.flink.runtime.operators.util
Methods in org.apache.flink.runtime.operators.util that return TaskConfig Modifier and Type Method Description TaskConfig
TaskConfig. getChainedStubConfig(int chainPos)
TaskConfig
TaskConfig. getIterationHeadFinalOutputConfig()
Methods in org.apache.flink.runtime.operators.util with parameters of type TaskConfig Modifier and Type Method Description void
TaskConfig. addChainedTask(Class<? extends ChainedDriver> chainedTaskClass, TaskConfig conf, String taskName)
void
TaskConfig. setIterationHeadFinalOutputConfig(TaskConfig conf)
-