Class and Description 

AggregateOperator
This operator represents the application of a "aggregate" operation on a data set, and the result
data set produced by the function.

CoGroupOperator.CoGroupOperatorSets
Intermediate step of a CoGroup transformation.

CrossOperator.DefaultCross
A Cross transformation that wraps pairs of crossed elements into
Tuple2 . 
CustomUnaryOperation 
DataSink
An operation that allows storing data results.

DataSource
An operation that creates a new data set (data source).

DeltaIteration
The DeltaIteration represents the start of a delta iteration.

DistinctOperator
This operator represents the application of a "distinct" function on a data set, and the result
data set produced by the function.

FilterOperator
This operator represents the application of a "filter" function on a data set, and the result
data set produced by the function.

FlatMapOperator
This operator represents the application of a "flatMap" function on a data set, and the result
data set produced by the function.

GroupCombineOperator
This operator behaves like the GroupReduceOperator with Combine but only runs the Combine part
which reduces all data locally in their partitions.

GroupReduceOperator
This operator represents the application of a "reduceGroup" function on a data set, and the
result data set produced by the function.

IterativeDataSet
The IterativeDataSet represents the start of an iteration.

JoinOperator.JoinOperatorSets
Intermediate step of a Join transformation.

MapOperator
This operator represents the application of a "map" function on a data set, and the result data
set produced by the function.

MapPartitionOperator
This operator represents the application of a "mapPartition" function on a data set, and the
result data set produced by the function.

PartitionOperator
This operator represents a partitioning.

ProjectOperator
This operator represents the application of a projection operation on a data set, and the result
data set produced by the function.

ReduceOperator
This operator represents the application of a "reduce" function on a data set, and the result
data set produced by the function.

SortPartitionOperator
This operator represents a DataSet with locally sorted partitions.

UnionOperator
Java API operator for union of two data sets.

UnsortedGrouping
A
Grouping that is unsorted. 
Class and Description 

DataSource
An operation that creates a new data set (data source).

Class and Description 

AggregateOperator
This operator represents the application of a "aggregate" operation on a data set, and the result
data set produced by the function.

CoGroupOperator
A
DataSet that is the result of a CoGroup transformation. 
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate
Intermediate step of a CoGroup transformation.

CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction
An intermediate
CoGroupOperator without CoGroupFunction applied yet. 
CrossOperator
A
DataSet that is the result of a Cross transformation. 
CrossOperator.CrossProjection 
CrossOperator.ProjectCross 
CrossOperator.ProjectCrossFunction 
DataSink
An operation that allows storing data results.

DataSource
An operation that creates a new data set (data source).

DeltaIteration
The DeltaIteration represents the start of a delta iteration.

DeltaIteration.SolutionSetPlaceHolder
A
DataSet that acts as a placeholder for the solution set during the iteration. 
DeltaIteration.WorksetPlaceHolder
A
DataSet that acts as a placeholder for the workset during the iteration. 
DistinctOperator
This operator represents the application of a "distinct" function on a data set, and the result
data set produced by the function.

GroupCombineOperator
This operator behaves like the GroupReduceOperator with Combine but only runs the Combine part
which reduces all data locally in their partitions.

Grouping
Grouping is an intermediate step for a transformation on a grouped DataSet.

GroupReduceOperator
This operator represents the application of a "reduceGroup" function on a data set, and the
result data set produced by the function.

IterativeDataSet
The IterativeDataSet represents the start of an iteration.

JoinOperator
A
DataSet that is the result of a Join transformation. 
JoinOperator.DefaultJoin
A Join transformation that wraps pairs of joining elements into
Tuple2 . 
JoinOperator.EquiJoin
A Join transformation that applies a
JoinFunction on each pair of joining elements. 
JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate
Intermediate step of a Join transformation.

JoinOperator.ProjectJoin 
Operator
Base class of all operators in the Java API.

PartitionOperator
This operator represents a partitioning.

ProjectOperator
This operator represents the application of a projection operation on a data set, and the result
data set produced by the function.

ReduceOperator
This operator represents the application of a "reduce" function on a data set, and the result
data set produced by the function.

SingleInputOperator
Base class for operations that operates on a single input data set.

SingleInputUdfOperator
The SingleInputUdfOperator is the base class of all unary operators that execute
userdefined functions (UDFs).

SortedGrouping
SortedGrouping is an intermediate step for a transformation on a grouped and sorted DataSet.

SortPartitionOperator
This operator represents a DataSet with locally sorted partitions.

TwoInputOperator
Base class for operations that operates on two input data sets.

TwoInputUdfOperator
The TwoInputUdfOperator is the base class of all binary operators that execute
userdefined functions (UDFs).

UdfOperator
This interface marks operators as operators that execute userdefined functions (UDFs), such as
RichMapFunction , RichReduceFunction , or RichCoGroupFunction . 
UnionOperator
Java API operator for union of two data sets.

UnsortedGrouping
A
Grouping that is unsorted. 
Class and Description 

JoinOperator
A
DataSet that is the result of a Join transformation. 
JoinOperator.DefaultJoin
A Join transformation that wraps pairs of joining elements into
Tuple2 . 
Class and Description 

DataSink
An operation that allows storing data results.

MapPartitionOperator
This operator represents the application of a "mapPartition" function on a data set, and the
result data set produced by the function.

PartitionOperator
This operator represents a partitioning.

Class and Description 

Grouping
Grouping is an intermediate step for a transformation on a grouped DataSet.

Operator
Base class of all operators in the Java API.

SingleInputOperator
Base class for operations that operates on a single input data set.

Class and Description 

CustomUnaryOperation 
Class and Description 

CustomUnaryOperation 
Class and Description 

CustomUnaryOperation 
Class and Description 

DataSource
An operation that creates a new data set (data source).

Class and Description 

DataSink
An operation that allows storing data results.

Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.