org.apache.flink.api.java.operators.translation
Classes
CombineToGroupCombineWrapper
KeyExtractingMapper
KeyRemovingMapper
PlanBothUnwrappingCoGroupOperator
PlanBothUnwrappingCoGroupOperator.TupleBothUnwrappingCoGrouper
PlanFilterOperator
PlanFilterOperator.FlatMapFilter
PlanLeftUnwrappingCoGroupOperator
PlanLeftUnwrappingCoGroupOperator.TupleLeftUnwrappingCoGrouper
PlanProjectOperator
PlanProjectOperator.MapProjector
PlanRightUnwrappingCoGroupOperator
PlanRightUnwrappingCoGroupOperator.TupleRightUnwrappingCoGrouper
PlanUnwrappingGroupCombineOperator
PlanUnwrappingGroupCombineOperator.TupleUnwrappingGroupCombiner
PlanUnwrappingReduceGroupOperator
PlanUnwrappingReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer
PlanUnwrappingReduceGroupOperator.TupleUnwrappingNonCombinableGroupReducer
PlanUnwrappingReduceOperator
PlanUnwrappingReduceOperator.ReduceWrapper
PlanUnwrappingSortedGroupCombineOperator
PlanUnwrappingSortedGroupCombineOperator.TupleUnwrappingGroupReducer
PlanUnwrappingSortedReduceGroupOperator
PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer
PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingNonCombinableGroupReducer
RichCombineToGroupCombineWrapper
Tuple3UnwrappingIterator
Tuple3WrappingCollector
TupleLeftUnwrappingJoiner
TupleRightUnwrappingJoiner
TupleUnwrappingIterator
TupleUnwrappingJoiner
TupleWrappingCollector
TwoKeyExtractingMapper
WrappingFunction