org.apache.flink.api.java.operators.translation
Classes
CombineToGroupCombineWrapper
KeyExtractingMapper
KeyRemovingMapper
PlanBothUnwrappingCoGroupOperator
PlanFilterOperator
PlanFilterOperator.FlatMapFilter
PlanLeftUnwrappingCoGroupOperator
PlanProjectOperator
PlanRightUnwrappingCoGroupOperator
PlanUnwrappingGroupCombineOperator
PlanUnwrappingReduceGroupOperator
PlanUnwrappingReduceOperator
PlanUnwrappingSortedGroupCombineOperator
PlanUnwrappingSortedReduceGroupOperator
RichCombineToGroupCombineWrapper
Tuple3UnwrappingIterator
Tuple3WrappingCollector
TupleLeftUnwrappingJoiner
TupleRightUnwrappingJoiner
TupleUnwrappingIterator
TupleUnwrappingJoiner
TupleWrappingCollector
TwoKeyExtractingMapper
WrappingFunction