Modifier and Type | Class and Description |
---|---|
class |
BulkIterationBase<T> |
class |
FilterOperatorBase<T,FT extends FlatMapFunction<T,T>> |
class |
FlatMapOperatorBase<IN,OUT,FT extends FlatMapFunction<IN,OUT>> |
class |
GroupCombineOperatorBase<IN,OUT,FT extends GroupCombineFunction<IN,OUT>>
Base operator for the combineGroup transformation.
|
class |
GroupReduceOperatorBase<IN,OUT,FT extends GroupReduceFunction<IN,OUT>> |
class |
MapOperatorBase<IN,OUT,FT extends MapFunction<IN,OUT>> |
class |
MapPartitionOperatorBase<IN,OUT,FT extends MapPartitionFunction<IN,OUT>> |
class |
PartitionOperatorBase<IN> |
class |
ReduceOperatorBase<T,FT extends ReduceFunction<T>>
Base data flow operator for Reduce user-defined functions.
|
class |
SortPartitionOperatorBase<IN> |
Modifier and Type | Method and Description |
---|---|
static <T,K> SingleInputOperator<?,T,?> |
KeyFunctions.appendKeyRemover(Operator<Tuple2<K,T>> inputWithKey,
Keys.SelectorFunctionKeys<T,K> key) |
protected SingleInputOperator<?,IN,?> |
ReduceOperator.translateToDataFlow(Operator<IN> input) |
protected SingleInputOperator<?,T,?> |
SortPartitionOperator.translateToDataFlow(Operator<T> input) |
protected SingleInputOperator<T,T,?> |
IterativeDataSet.translateToDataFlow(Operator<T> input) |
protected SingleInputOperator<?,T,?> |
DistinctOperator.translateToDataFlow(Operator<T> input) |
protected SingleInputOperator<?,T,?> |
PartitionOperator.translateToDataFlow(Operator<T> input) |
Modifier and Type | Class and Description |
---|---|
class |
PlanFilterOperator<T> |
class |
PlanProjectOperator<T,R extends Tuple>
A map operator that retains a subset of fields from incoming tuples.
|
class |
PlanUnwrappingGroupCombineOperator<IN,OUT,K>
A group combine operator that takes 2-tuples (key-value pairs), and applies the group combine
operation only on the unwrapped values.
|
class |
PlanUnwrappingReduceGroupOperator<IN,OUT,K>
A reduce operator that takes 2-tuples (key-value pairs), and applies the group reduce operation
only on the unwrapped values.
|
class |
PlanUnwrappingReduceOperator<T,K>
A reduce operator that takes 2-tuples (key-value pairs), and applies the reduce operation only on
the unwrapped values.
|
class |
PlanUnwrappingSortedGroupCombineOperator<IN,OUT,K1,K2>
A reduce operator that takes 3-tuples (groupKey, sortKey, value), and applies the sorted partial
group reduce operation only on the unwrapped values.
|
class |
PlanUnwrappingSortedReduceGroupOperator<IN,OUT,K1,K2>
A reduce operator that takes 3-tuples (groupKey, sortKey, value), and applies the sorted group
reduce operation only on the unwrapped values.
|
Modifier and Type | Method and Description |
---|---|
SingleInputOperator<?,?,?> |
SingleInputNode.getOperator() |
Constructor and Description |
---|
MapNode(SingleInputOperator<?,?,?> operator)
Creates a new MapNode for the given operator.
|
MapPartitionNode(SingleInputOperator<?,?,?> operator)
Creates a new MapNode for the given contract.
|
SingleInputNode(SingleInputOperator<?,?,?> programOperator)
Creates a new node with a single input for the optimizer plan.
|
UnaryOperatorNode(String name,
SingleInputOperator<?,?,?> operator,
boolean onDynamicPath) |
Modifier and Type | Class and Description |
---|---|
class |
NoOpUnaryUdfOp<OUT> |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.