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>
KeyRemovingMapper<T,K>
PlanBothUnwrappingCoGroupOperator<I1,I2,OUT,K>
PlanBothUnwrappingCoGroupOperator.TupleBothUnwrappingCoGrouper<I1,I2,OUT,K>
PlanFilterOperator<T>
PlanFilterOperator.FlatMapFilter<T>
PlanLeftUnwrappingCoGroupOperator<I1,I2,OUT,K>
PlanLeftUnwrappingCoGroupOperator.TupleLeftUnwrappingCoGrouper<I1,I2,OUT,K>
PlanProjectOperator<T,R extends Tuple>
PlanProjectOperator.MapProjector<T extends Tuple,R extends Tuple>
PlanRightUnwrappingCoGroupOperator<I1,I2,OUT,K>
PlanRightUnwrappingCoGroupOperator.TupleRightUnwrappingCoGrouper<I1,I2,OUT,K>
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.
PlanUnwrappingGroupCombineOperator.TupleUnwrappingGroupCombiner<IN,OUT,K>
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.
PlanUnwrappingReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer<IN,OUT,K>
PlanUnwrappingReduceGroupOperator.TupleUnwrappingNonCombinableGroupReducer<IN,OUT,K>
PlanUnwrappingReduceOperator<T,K>	A reduce operator that takes 2-tuples (key-value pairs), and applies the reduce operation only on the unwrapped values.
PlanUnwrappingReduceOperator.ReduceWrapper<T,K>
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.
PlanUnwrappingSortedGroupCombineOperator.TupleUnwrappingGroupReducer<IN,OUT,K1,K2>
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.
PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer<IN,OUT,K1,K2>
PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingNonCombinableGroupReducer<IN,OUT,K1,K2>
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>
TupleRightUnwrappingJoiner<I1,I2,OUT,K>
TupleUnwrappingIterator<T,K>	An iterator that reads 2-tuples (key value pairs) and returns only the values (second field).
TupleUnwrappingJoiner<I1,I2,OUT,K>
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>
WrappingFunction<T extends Function>