Package | Description |
---|---|
org.apache.flink.runtime.operators | |
org.apache.flink.runtime.operators.util |
Modifier and Type | Interface and Description |
---|---|
interface |
ResettableDriver<S extends Function,OT>
This interface marks a
Driver as resettable, meaning that will reset part of their internal state but
otherwise reuse existing data structures. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCachedBuildSideJoinDriver<IT1,IT2,OT> |
class |
AbstractOuterJoinDriver<IT1,IT2,OT>
The abstract outer join driver implements the logic of an outer join operator at runtime.
|
class |
AllGroupCombineDriver<IN,OUT>
Non-chained driver for the partial group reduce operator that acts like a combiner with a custom output type OUT.
|
class |
AllGroupReduceDriver<IT,OT>
GroupReduceDriver task which is executed by a Task Manager.
|
class |
AllReduceDriver<T>
Reduce task which is executed by a Task Manager.
|
class |
BuildFirstCachedJoinDriver<IT1,IT2,OT> |
class |
BuildSecondCachedJoinDriver<IT1,IT2,OT> |
class |
CoGroupDriver<IT1,IT2,OT>
CoGroup task which is executed by a Task Manager.
|
class |
CoGroupRawDriver<IT1,IT2,OT> |
class |
CoGroupWithSolutionSetFirstDriver<IT1,IT2,OT> |
class |
CoGroupWithSolutionSetSecondDriver<IT1,IT2,OT> |
class |
CrossDriver<T1,T2,OT>
Cross task which is executed by a Task Manager.
|
class |
FlatMapDriver<IT,OT>
Map task which is executed by a Task Manager.
|
class |
FullOuterJoinDriver<IT1,IT2,OT>
The full outer join driver implements the logic of an outer join operator at runtime.
|
class |
GroupReduceCombineDriver<IN,OUT>
Non-chained combine driver which is used for a CombineGroup transformation or a GroupReduce transformation where
the user supplied a RichGroupReduceFunction with a combine method.
|
class |
GroupReduceDriver<IT,OT>
GroupReduce task which is executed by a Task Manager.
|
class |
JoinDriver<IT1,IT2,OT>
The join driver implements the logic of a join operator at runtime.
|
class |
JoinWithSolutionSetFirstDriver<IT1,IT2,OT> |
class |
JoinWithSolutionSetSecondDriver<IT1,IT2,OT> |
class |
LeftOuterJoinDriver<IT1,IT2,OT>
The left outer join driver implements the logic of an outer join operator at runtime.
|
class |
MapDriver<IT,OT>
Map task which is executed by a Task Manager.
|
class |
MapPartitionDriver<IT,OT>
MapPartition task which is executed by a Task Manager.
|
class |
NoOpDriver<T>
A driver that does nothing but forward data from its input to its output.
|
class |
ReduceCombineDriver<T>
Combine operator for Reduce functions, standalone (not chained).
|
class |
ReduceDriver<T>
Reduce driver which is executed by a Task Manager.
|
class |
RightOuterJoinDriver<IT1,IT2,OT>
The right outer join driver implements the logic of an outer join operator at runtime.
|
class |
UnionWithTempOperator<T> |
Modifier and Type | Field and Description |
---|---|
protected Driver<S,OT> |
BatchTask.driver
The driver that invokes the user code (the stub implementation).
|
Modifier and Type | Method and Description |
---|---|
Class<? extends Driver<?,?>> |
DriverStrategy.getDriverClass() |
Modifier and Type | Method and Description |
---|---|
<S extends Function,OT> |
TaskConfig.getDriver() |
Modifier and Type | Method and Description |
---|---|
void |
TaskConfig.setDriver(Class<? extends Driver> driver) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.