Uses of Interface
org.apache.flink.runtime.operators.PactTaskContext

Packages that use PactTaskContext

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

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

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

Modifier and Type	Class and Description
class	AbstractIterativePactTask<S extends org.apache.flink.api.common.functions.Function,OT> The abstract base class for all tasks able to participate in an iteration.
class	IterationHeadPactTask<X,Y,S extends org.apache.flink.api.common.functions.Function,OT> The head is responsible for coordinating an iteration and can run a PactDriver inside.
class	IterationIntermediatePactTask<S extends org.apache.flink.api.common.functions.Function,OT> An intermediate iteration task, which runs a Driver}inside.
class	IterationTailPactTask<S extends org.apache.flink.api.common.functions.Function,OT> An iteration tail, which runs a driver inside.

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

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

Modifier and Type	Class and Description
class	RegularPactTask<S extends org.apache.flink.api.common.functions.Function,OT> The base class for all tasks.

Fields in org.apache.flink.runtime.operators declared as PactTaskContext

Modifier and Type	Field and Description
protected PactTaskContext<org.apache.flink.api.common.functions.FlatJoinFunction<IT1,IT2,OT>,OT>	MatchDriver.taskContext

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

Modifier and Type	Method and Description
void	NoOpDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.AbstractRichFunction,T> context)
void	CoGroupWithSolutionSetFirstDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.CoGroupFunction<IT1,IT2,OT>,OT> context)
void	CoGroupDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.CoGroupFunction<IT1,IT2,OT>,OT> context)
void	CoGroupRawDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.CoGroupFunction<IT1,IT2,OT>,OT> context)
void	CoGroupWithSolutionSetSecondDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.CoGroupFunction<IT1,IT2,OT>,OT> context)
void	CrossDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.CrossFunction<T1,T2,OT>,OT> context)
void	JoinWithSolutionSetSecondDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.FlatJoinFunction<IT1,IT2,OT>,OT> context)
void	MatchDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.FlatJoinFunction<IT1,IT2,OT>,OT> context)
void	JoinWithSolutionSetFirstDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.FlatJoinFunction<IT1,IT2,OT>,OT> context)
void	FlatMapDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.FlatMapFunction<IT,OT>,OT> context)
void	UnionWithTempOperator.setup(PactTaskContext<org.apache.flink.api.common.functions.Function,T> context)
void	CollectorMapDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.GenericCollectorMap<IT,OT>,OT> context)
void	AllGroupCombineDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>,OUT> context)
void	GroupReduceCombineDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>,OUT> context)
void	GroupReduceDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.GroupReduceFunction<IT,OT>,OT> context)
void	AllGroupReduceDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.GroupReduceFunction<IT,OT>,OT> context)
void	MapDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.MapFunction<IT,OT>,OT> context)
void	MapPartitionDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.MapPartitionFunction<IT,OT>,OT> context)
void	ReduceDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.ReduceFunction<T>,T> context)
void	ReduceCombineDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.ReduceFunction<T>,T> context)
void	AllReduceDriver.setup(PactTaskContext<org.apache.flink.api.common.functions.ReduceFunction<T>,T> context)
void	PactDriver.setup(PactTaskContext<S,OT> context)