Package  Description 

org.apache.flink.api.java.operators 
Modifier and Type  Interface and Description 

interface 
UdfOperator<O extends UdfOperator<O>>
This interface marks operators as operators that execute userdefined functions (UDFs), such as
RichMapFunction , RichReduceFunction , or RichCoGroupFunction . 
Modifier and Type  Class and Description 

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

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