Uses of Class
org.apache.flink.api.common.operators.AbstractUdfOperator

Packages that use AbstractUdfOperator

Package	Description
org.apache.flink.api.common.operators
org.apache.flink.api.common.operators.base

Uses of AbstractUdfOperator in org.apache.flink.api.common.operators

Subclasses of AbstractUdfOperator in org.apache.flink.api.common.operators

Modifier and Type	Class	Description
class	DualInputOperator<IN1,IN2,OUT,FT extends org.apache.flink.api.common.functions.Function>	Abstract operator superclass for all operators that have two inputs, like "Join", "CoGroup", or "Cross".
class	SingleInputOperator<IN,OUT,FT extends org.apache.flink.api.common.functions.Function>	Abstract superclass for all operators that have one input like "map" or "reduce".
class	Union<T>	This operator represents a Union between two inputs.

Uses of AbstractUdfOperator in org.apache.flink.api.common.operators.base

Subclasses of AbstractUdfOperator in org.apache.flink.api.common.operators.base

Modifier and Type	Class	Description
class	BulkIterationBase<T>
class	CoGroupOperatorBase<IN1,IN2,OUT,FT extends CoGroupFunction<IN1,IN2,OUT>>
class	CoGroupRawOperatorBase<IN1,IN2,OUT,FT extends CoGroupFunction<IN1,IN2,OUT>>
class	CrossOperatorBase<IN1,IN2,OUT,FT extends CrossFunction<IN1,IN2,OUT>>
class	DeltaIterationBase<ST,WT>	A DeltaIteration is similar to a BulkIterationBase, but maintains state across the individual iteration steps.
class	FilterOperatorBase<T,FT extends FlatMapFunction<T,T>>
class	FlatMapOperatorBase<IN,OUT,FT extends FlatMapFunction<IN,OUT>>
class	GroupCombineOperatorBase<IN,OUT,FT extends GroupCombineFunction<IN,OUT>>	Base operator for the combineGroup transformation.
class	GroupReduceOperatorBase<IN,OUT,FT extends GroupReduceFunction<IN,OUT>>
class	InnerJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>>
class	JoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>>
class	MapOperatorBase<IN,OUT,FT extends MapFunction<IN,OUT>>
class	MapPartitionOperatorBase<IN,OUT,FT extends MapPartitionFunction<IN,OUT>>
class	OuterJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>>
class	PartitionOperatorBase<IN>
class	ReduceOperatorBase<T,FT extends org.apache.flink.api.common.functions.ReduceFunction<T>>	Base data flow operator for Reduce user-defined functions.
class	SortPartitionOperatorBase<IN>