Package  Description 

org.apache.flink.api.java.operators  
org.apache.flink.api.scala.operators 
Modifier and Type  Class and Description 

class 
Operator<OUT,O extends Operator<OUT,O>>
Base class of all operators in the Java API.

Modifier and Type  Class and Description 

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

class 
CoGroupOperator<I1,I2,OUT>
A
DataSet that is the result of a CoGroup transformation. 
class 
CoGroupRawOperator<I1,I2,OUT>
A
DataSet that is the result of a CoGroup transformation. 
class 
CrossOperator<I1,I2,OUT>
A
DataSet that is the result of a Cross transformation. 
static class 
CrossOperator.DefaultCross<I1,I2>
A Cross transformation that wraps pairs of crossed elements into
Tuple2 . 
static class 
CrossOperator.ProjectCross<I1,I2,OUT extends Tuple>

class 
DataSource<OUT>
An operation that creates a new data set (data source).

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

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

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

class 
GroupCombineOperator<IN,OUT>
This operator behaves like the GroupReduceOperator with Combine but only runs the Combine part which reduces all data
locally in their partitions.

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

class 
IterativeDataSet<T>
The IterativeDataSet represents the start of an iteration.

class 
JoinOperator<I1,I2,OUT>
A
DataSet that is the result of a Join transformation. 
static class 
JoinOperator.DefaultJoin<I1,I2>
A Join transformation that wraps pairs of joining elements into
Tuple2 . 
static class 
JoinOperator.EquiJoin<I1,I2,OUT>
A Join transformation that applies a
JoinFunction on each pair of joining elements. 
static class 
JoinOperator.ProjectJoin<I1,I2,OUT extends Tuple>

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

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

class 
PartitionOperator<T>
This operator represents a partitioning.

class 
ProjectOperator<IN,OUT extends Tuple>
This operator represents the application of a projection operation on a data set, and the
result data set produced by the function.

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

class 
SingleInputOperator<IN,OUT,O extends SingleInputOperator<IN,OUT,O>>
Base class for operations that operates on a single input data set.

class 
SingleInputUdfOperator<IN,OUT,O extends SingleInputUdfOperator<IN,OUT,O>>
The SingleInputUdfOperator is the base class of all unary operators that execute
userdefined functions (UDFs).

class 
SortPartitionOperator<T>
This operator represents a DataSet with locally sorted partitions.

class 
TwoInputOperator<IN1,IN2,OUT,O extends TwoInputOperator<IN1,IN2,OUT,O>>
Base class for operations that operates on two input data sets.

class 
TwoInputUdfOperator<IN1,IN2,OUT,O extends TwoInputUdfOperator<IN1,IN2,OUT,O>>
The TwoInputUdfOperator is the base class of all binary operators that execute
userdefined functions (UDFs).

class 
UnionOperator<T>
Java API operator for union of two data sets.

Modifier and Type  Class and Description 

class 
ScalaAggregateOperator<IN>
This operator represents the application of a "aggregate" operation on a data set, and the
result data set produced by the function.

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