Uses of Interface
org.apache.flink.runtime.jobgraph.tasks.CoordinatedTask
-
Packages that use CoordinatedTask Package Description org.apache.flink.runtime.iterative.task org.apache.flink.runtime.jobgraph.tasks org.apache.flink.runtime.operators -
-
Uses of CoordinatedTask in org.apache.flink.runtime.iterative.task
Classes in org.apache.flink.runtime.iterative.task that implement CoordinatedTask Modifier and Type Class Description classAbstractIterativeTask<S extends org.apache.flink.api.common.functions.Function,OT>The abstract base class for all tasks able to participate in an iteration.classIterationHeadTask<X,Y,S extends org.apache.flink.api.common.functions.Function,OT>The head is responsible for coordinating an iteration and can run aDriverinside.classIterationIntermediateTask<S extends org.apache.flink.api.common.functions.Function,OT>An intermediate iteration task, which runs aDriverinside.classIterationSynchronizationSinkTaskThe task responsible for synchronizing all iteration heads, implemented as an output task.classIterationTailTask<S extends org.apache.flink.api.common.functions.Function,OT>An iteration tail, which runs a driver inside. -
Uses of CoordinatedTask in org.apache.flink.runtime.jobgraph.tasks
Classes in org.apache.flink.runtime.jobgraph.tasks that implement CoordinatedTask Modifier and Type Class Description classAbstractInvokableA base implementation ofTaskInvokable,CheckpointableTask, andCoordinatedTaskwith most methods throwingUnsupportedOperationExceptionor doing nothing. -
Uses of CoordinatedTask in org.apache.flink.runtime.operators
Classes in org.apache.flink.runtime.operators that implement CoordinatedTask Modifier and Type Class Description classBatchTask<S extends org.apache.flink.api.common.functions.Function,OT>The base class for all batch tasks.classDataSinkTask<IT>DataSinkTask which is executed by a task manager.classDataSourceTask<OT>DataSourceTask which is executed by a task manager.
-