Uses of Interface
org.apache.flink.api.java.operators.UdfOperator

Packages that use UdfOperator

Package	Description
org.apache.flink.api.java.operators

Uses of UdfOperator in org.apache.flink.api.java.operators

Classes in org.apache.flink.api.java.operators with type parameters of type UdfOperator

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

Classes in org.apache.flink.api.java.operators that implement UdfOperator

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> A Cross transformation that projects crossing elements or fields of crossing Tuples into result Tuples.
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> A Join transformation that projects joining elements or fields of joining Tuples into result Tuples.
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 user-defined 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 user-defined functions (UDFs).