Uses of Interface
org.apache.flink.runtime.jobgraph.tasks.CheckpointableTask
-
Packages that use CheckpointableTask Package Description org.apache.flink.runtime.iterative.task org.apache.flink.runtime.jobgraph.tasks org.apache.flink.runtime.operators -
-
Uses of CheckpointableTask in org.apache.flink.runtime.iterative.task
Classes in org.apache.flink.runtime.iterative.task that implement CheckpointableTask 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 CheckpointableTask in org.apache.flink.runtime.jobgraph.tasks
Classes in org.apache.flink.runtime.jobgraph.tasks that implement CheckpointableTask Modifier and Type Class Description classAbstractInvokableA base implementation ofTaskInvokable,CheckpointableTask, andCoordinatedTaskwith most methods throwingUnsupportedOperationExceptionor doing nothing. -
Uses of CheckpointableTask in org.apache.flink.runtime.operators
Classes in org.apache.flink.runtime.operators that implement CheckpointableTask 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.
-