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
org.apache.flink.api.java.operators.translation
org.apache.flink.optimizer.util

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

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

Modifier and Type	Class and Description
class	DualInputOperator<IN1,IN2,OUT,FT extends Function> Abstract operator superclass for all operators that have two inputs, like "Join", "CoGroup", or "Cross".
class	SingleInputOperator<IN,OUT,FT extends Function> Abstract superclass for 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 and 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 ReduceFunction<T>> Base data flow operator for Reduce user-defined functions.
class	SortPartitionOperatorBase<IN>

Uses of AbstractUdfOperator in org.apache.flink.api.java.operators.translation

Subclasses of AbstractUdfOperator in org.apache.flink.api.java.operators.translation

Modifier and Type	Class and Description
class	PlanBothUnwrappingCoGroupOperator<I1,I2,OUT,K> A co group operator that applies the operation only on the unwrapped values.
class	PlanFilterOperator<T>
class	PlanLeftUnwrappingCoGroupOperator<I1,I2,OUT,K> A co group operator that applies the operation only on the unwrapped values on the left.
class	PlanProjectOperator<T,R extends Tuple> A map operator that retains a subset of fields from incoming tuples.
class	PlanRightUnwrappingCoGroupOperator<I1,I2,OUT,K> A co group operator that applies the operation only on the unwrapped values on the right.
class	PlanUnwrappingGroupCombineOperator<IN,OUT,K> A group combine operator that takes 2-tuples (key-value pairs), and applies the group combine operation only on the unwrapped values.
class	PlanUnwrappingReduceGroupOperator<IN,OUT,K> A reduce operator that takes 2-tuples (key-value pairs), and applies the group reduce operation only on the unwrapped values.
class	PlanUnwrappingReduceOperator<T,K> A reduce operator that takes 2-tuples (key-value pairs), and applies the reduce operation only on the unwrapped values.
class	PlanUnwrappingSortedGroupCombineOperator<IN,OUT,K1,K2> A reduce operator that takes 3-tuples (groupKey, sortKey, value), and applies the sorted partial group reduce operation only on the unwrapped values.
class	PlanUnwrappingSortedReduceGroupOperator<IN,OUT,K1,K2> A reduce operator that takes 3-tuples (groupKey, sortKey, value), and applies the sorted group reduce operation only on the unwrapped values.

Uses of AbstractUdfOperator in org.apache.flink.optimizer.util

Subclasses of AbstractUdfOperator in org.apache.flink.optimizer.util

Modifier and Type	Class and Description
class	NoOpBinaryUdfOp<OUT>
class	NoOpUnaryUdfOp<OUT>