Package | Description |
---|---|
org.apache.flink.runtime.iterative.task | |
org.apache.flink.runtime.operators |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
BatchTask<S extends Function,OT>
The base class for all batch tasks.
|
Modifier and Type | Field and Description |
---|---|
protected TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> |
AbstractOuterJoinDriver.taskContext |
protected TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> |
JoinDriver.taskContext |
Modifier and Type | Method and Description |
---|---|
void |
NoOpDriver.setup(TaskContext<AbstractRichFunction,T> context) |
void |
CoGroupWithSolutionSetSecondDriver.setup(TaskContext<CoGroupFunction<IT1,IT2,OT>,OT> context) |
void |
CoGroupDriver.setup(TaskContext<CoGroupFunction<IT1,IT2,OT>,OT> context) |
void |
CoGroupRawDriver.setup(TaskContext<CoGroupFunction<IT1,IT2,OT>,OT> context) |
void |
CoGroupWithSolutionSetFirstDriver.setup(TaskContext<CoGroupFunction<IT1,IT2,OT>,OT> context) |
void |
CrossDriver.setup(TaskContext<CrossFunction<T1,T2,OT>,OT> context) |
void |
JoinWithSolutionSetFirstDriver.setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context) |
void |
JoinWithSolutionSetSecondDriver.setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context) |
void |
AbstractOuterJoinDriver.setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context) |
void |
JoinDriver.setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context) |
void |
FlatMapDriver.setup(TaskContext<FlatMapFunction<IT,OT>,OT> context) |
void |
UnionWithTempOperator.setup(TaskContext<Function,T> context) |
void |
GroupReduceCombineDriver.setup(TaskContext<GroupCombineFunction<IN,OUT>,OUT> context) |
void |
AllGroupCombineDriver.setup(TaskContext<GroupCombineFunction<IN,OUT>,OUT> context) |
void |
AllGroupReduceDriver.setup(TaskContext<GroupReduceFunction<IT,OT>,OT> context) |
void |
GroupReduceDriver.setup(TaskContext<GroupReduceFunction<IT,OT>,OT> context) |
void |
MapDriver.setup(TaskContext<MapFunction<IT,OT>,OT> context) |
void |
MapPartitionDriver.setup(TaskContext<MapPartitionFunction<IT,OT>,OT> context) |
void |
ReduceCombineDriver.setup(TaskContext<ReduceFunction<T>,T> context) |
void |
AllReduceDriver.setup(TaskContext<ReduceFunction<T>,T> context) |
void |
ReduceDriver.setup(TaskContext<ReduceFunction<T>,T> context) |
void |
Driver.setup(TaskContext<S,OT> context) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.