BulkIterationBase(UnaryOperatorInformation<T,T> operatorInfo) |
BulkIterationBase(UnaryOperatorInformation<T,T> operatorInfo,
String name) |
FilterOperatorBase(Class<? extends FT> udf,
UnaryOperatorInformation<T,T> operatorInfo,
String name) |
FilterOperatorBase(FT udf,
UnaryOperatorInformation<T,T> operatorInfo,
String name) |
FilterOperatorBase(UserCodeWrapper<FT> udf,
UnaryOperatorInformation<T,T> operatorInfo,
String name) |
FlatMapOperatorBase(Class<? extends FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
FlatMapOperatorBase(FT udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
FlatMapOperatorBase(UserCodeWrapper<FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
GroupCombineOperatorBase(FT udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
int[] keyPositions,
String name) |
GroupReduceOperatorBase(Class<? extends FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
int[] keyPositions,
String name) |
GroupReduceOperatorBase(Class<? extends FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
GroupReduceOperatorBase(FT udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
int[] keyPositions,
String name) |
GroupReduceOperatorBase(FT udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
GroupReduceOperatorBase(UserCodeWrapper<FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
int[] keyPositions,
String name) |
GroupReduceOperatorBase(UserCodeWrapper<FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
MapOperatorBase(Class<? extends FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
MapOperatorBase(FT udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
MapOperatorBase(UserCodeWrapper<FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
MapPartitionOperatorBase(Class<? extends FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
MapPartitionOperatorBase(FT udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
MapPartitionOperatorBase(UserCodeWrapper<FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo,
PartitionOperatorBase.PartitionMethod pMethod,
int[] keys,
String name) |
PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo,
PartitionOperatorBase.PartitionMethod pMethod,
String name) |
ReduceOperatorBase(Class<? extends FT> udf,
UnaryOperatorInformation<T,T> operatorInfo,
int[] keyPositions,
String name)
Creates a grouped reduce data flow operator.
|
ReduceOperatorBase(Class<? extends FT> udf,
UnaryOperatorInformation<T,T> operatorInfo,
String name)
Creates a non-grouped reduce data flow operator (all-reduce).
|
ReduceOperatorBase(FT udf,
UnaryOperatorInformation<T,T> operatorInfo,
int[] keyPositions,
String name)
Creates a grouped reduce data flow operator.
|
ReduceOperatorBase(FT udf,
UnaryOperatorInformation<T,T> operatorInfo,
String name)
Creates a non-grouped reduce data flow operator (all-reduce).
|
ReduceOperatorBase(UserCodeWrapper<FT> udf,
UnaryOperatorInformation<T,T> operatorInfo,
int[] keyPositions,
String name)
Creates a grouped reduce data flow operator.
|
ReduceOperatorBase(UserCodeWrapper<FT> udf,
UnaryOperatorInformation<T,T> operatorInfo,
String name)
Creates a non-grouped reduce data flow operator (all-reduce).
|
SortPartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo,
Ordering partitionOrdering,
String name) |