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

Class Summary

Class	Description
CombineToGroupCombineWrapper<IN,OUT,F extends CombineFunction<IN,IN> & GroupReduceFunction<IN,OUT>>	A wrapper the wraps a function that implements both CombineFunction and GroupReduceFunction interfaces and makes it look like a function that implements GroupCombineFunction and GroupReduceFunction to the runtime.
KeyExtractingMapper<T,K>	Mapper that extracts keys.
KeyRemovingMapper<T,K>	Mapper that removes keys.
PlanBothUnwrappingCoGroupOperator<I1,I2,OUT,K>	A co group operator that applies the operation only on the unwrapped values.
PlanFilterOperator<T>
PlanFilterOperator.FlatMapFilter<T>
PlanLeftUnwrappingCoGroupOperator<I1,I2,OUT,K>	A co group operator that applies the operation only on the unwrapped values on the left.
PlanProjectOperator<T,R extends Tuple>	A map operator that retains a subset of fields from incoming tuples.
PlanRightUnwrappingCoGroupOperator<I1,I2,OUT,K>	A co group operator that applies the operation only on the unwrapped values on the right.
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.
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.
PlanUnwrappingReduceOperator<T,K>	A reduce operator that takes 2-tuples (key-value pairs), and applies the reduce operation only on the unwrapped values.
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.
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.
RichCombineToGroupCombineWrapper<IN,OUT,F extends RichGroupReduceFunction<IN,OUT> & CombineFunction<IN,IN>>	A wrapper the wraps a function that implements both CombineFunction and GroupReduceFunction interfaces and makes it look like a function that implements GroupCombineFunction and GroupReduceFunction to the runtime.
Tuple3UnwrappingIterator<T,K1,K2>	An iterator that reads 3-tuples (groupKey, sortKey, value) and returns only the values (third field).
Tuple3WrappingCollector<IN,K1,K2>	Needed to wrap tuples to Tuple3<groupKey, sortKey, value> for combine method of group reduce with key selector sorting.
TupleLeftUnwrappingJoiner<I1,I2,OUT,K>	Joiner that unwraps values from the left set before applying the join operation.
TupleRightUnwrappingJoiner<I1,I2,OUT,K>	Joiner that unwraps values from the right set before applying the join operation.
TupleUnwrappingIterator<T,K>	An iterator that reads 2-tuples (key value pairs) and returns only the values (second field).
TupleUnwrappingJoiner<I1,I2,OUT,K>	Joiner that unwraps both values before applying the join operation.
TupleWrappingCollector<IN,K>	Needed to wrap tuples to Tuple2<key, value> pairs for combine method of group reduce with key selector function.
TwoKeyExtractingMapper<T,K1,K2>	Mapper that extracts two keys of a value.
WrappingFunction<T extends Function>	Wrapper around Function.