Uses of Interface
org.apache.flink.runtime.jobgraph.tasks.TaskInvokable

Packages that use TaskInvokable

Package	Description
org.apache.flink.runtime.iterative.task
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.sort

Uses of TaskInvokable in org.apache.flink.runtime.iterative.task

Classes in org.apache.flink.runtime.iterative.task that implement TaskInvokable

Modifier and Type	Class	Description
class	AbstractIterativeTask<S extends org.apache.flink.api.common.functions.Function,OT>	The abstract base class for all tasks able to participate in an iteration.
class	IterationHeadTask<X,Y,S extends org.apache.flink.api.common.functions.Function,OT>	The head is responsible for coordinating an iteration and can run a Driver inside.
class	IterationIntermediateTask<S extends org.apache.flink.api.common.functions.Function,OT>	An intermediate iteration task, which runs a Driver inside.
class	IterationSynchronizationSinkTask	The task responsible for synchronizing all iteration heads, implemented as an output task.
class	IterationTailTask<S extends org.apache.flink.api.common.functions.Function,OT>	An iteration tail, which runs a driver inside.

Uses of TaskInvokable in org.apache.flink.runtime.jobgraph

Methods in org.apache.flink.runtime.jobgraph that return types with arguments of type TaskInvokable

Modifier and Type	Method	Description
Class<? extends TaskInvokable>	JobVertex.getInvokableClass(ClassLoader cl)	Returns the invokable class which represents the task of this vertex.

Method parameters in org.apache.flink.runtime.jobgraph with type arguments of type TaskInvokable

Modifier and Type	Method	Description
void	JobVertex.setInvokableClass(Class<? extends TaskInvokable> invokable)

Uses of TaskInvokable in org.apache.flink.runtime.jobgraph.tasks

Classes in org.apache.flink.runtime.jobgraph.tasks that implement TaskInvokable

Modifier and Type	Class	Description
class	AbstractInvokable	A base implementation of TaskInvokable, CheckpointableTask, and CoordinatedTask with most methods throwing UnsupportedOperationException or doing nothing.

Uses of TaskInvokable in org.apache.flink.runtime.operators

Classes in org.apache.flink.runtime.operators that implement TaskInvokable

Modifier and Type	Class	Description
class	BatchTask<S extends org.apache.flink.api.common.functions.Function,OT>	The base class for all batch tasks.
class	DataSinkTask<IT>	DataSinkTask which is executed by a task manager.
class	DataSourceTask<OT>	DataSourceTask which is executed by a task manager.

Uses of TaskInvokable in org.apache.flink.runtime.operators.sort

Methods in org.apache.flink.runtime.operators.sort with parameters of type TaskInvokable

Modifier and Type	Method	Description
static <E> ExternalSorterBuilder<E>	ExternalSorter.newBuilder(MemoryManager memoryManager, TaskInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializer<E> serializer, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, org.apache.flink.api.common.ExecutionConfig executionConfig)	Creates a builder for the ExternalSorter.

Constructors in org.apache.flink.runtime.operators.sort with parameters of type TaskInvokable

Constructor	Description
LargeRecordHandler(org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, org.apache.flink.api.common.typeutils.TypeComparator<T> comparator, IOManager ioManager, MemoryManager memManager, List<org.apache.flink.core.memory.MemorySegment> memory, TaskInvokable memoryOwner, int maxFilehandles, org.apache.flink.api.common.ExecutionConfig executionConfig)