Uses of Class
org.apache.flink.runtime.operators.BatchTask

Packages that use BatchTask

Package	Description
org.apache.flink.runtime.broadcast
org.apache.flink.runtime.iterative.task

Uses of BatchTask in org.apache.flink.runtime.broadcast

Methods in org.apache.flink.runtime.broadcast with parameters of type BatchTask

Modifier and Type	Method and Description
boolean	BroadcastVariableMaterialization.decrementReference(BatchTask<?,?> referenceHolder)
boolean	BroadcastVariableMaterialization.decrementReferenceIfHeld(BatchTask<?,?> referenceHolder)
<T> BroadcastVariableMaterialization<T,?>	BroadcastVariableManager.materializeBroadcastVariable(String name, int superstep, BatchTask<?,?> holder, MutableReader<?> reader, TypeSerializerFactory<T> serializerFactory) Materializes the broadcast variable for the given name, scoped to the given task and its iteration superstep.
void	BroadcastVariableMaterialization.materializeVariable(MutableReader<?> reader, TypeSerializerFactory<?> serializerFactory, BatchTask<?,?> referenceHolder)
void	BroadcastVariableManager.releaseAllReferencesFromTask(BatchTask<?,?> referenceHolder)
void	BroadcastVariableManager.releaseReference(BroadcastVariableKey key, BatchTask<?,?> referenceHolder)
void	BroadcastVariableManager.releaseReference(String name, int superstep, BatchTask<?,?> referenceHolder)

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

Subclasses of BatchTask in org.apache.flink.runtime.iterative.task

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