Package  Description 

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

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

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 
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 
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 
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.

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–2021 The Apache Software Foundation. All rights reserved.