org.apache.flink.api.java.operators.translation Class Hierarchy (Flink : Java 1.20.1-cp2 API)

Class Hierarchy

java.lang.Object
- org.apache.flink.api.common.functions.AbstractRichFunction (implements org.apache.flink.api.common.functions.RichFunction, java.io.Serializable)
  - org.apache.flink.api.common.functions.RichGroupCombineFunction<IN,OUT> (implements org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>)
    - org.apache.flink.api.java.operators.translation.RichCombineToGroupCombineWrapper<IN,OUT,F> (implements org.apache.flink.api.common.functions.GroupReduceFunction<T,O>)
  - org.apache.flink.api.common.functions.RichMapFunction<IN,OUT> (implements org.apache.flink.api.common.functions.MapFunction<T,O>)
    - org.apache.flink.api.java.operators.translation.KeyExtractingMapper<T,K>
    - org.apache.flink.api.java.operators.translation.KeyRemovingMapper<T,K>
    - org.apache.flink.api.java.operators.translation.TwoKeyExtractingMapper<T,K1,K2>
  - org.apache.flink.api.java.operators.translation.WrappingFunction<T>
    - org.apache.flink.api.java.operators.translation.PlanFilterOperator.FlatMapFilter<T> (implements org.apache.flink.api.common.functions.FlatMapFunction<T,O>)
    - org.apache.flink.api.java.operators.translation.TupleLeftUnwrappingJoiner<I1,I2,OUT,K> (implements org.apache.flink.api.common.functions.FlatJoinFunction<IN1,IN2,OUT>)
    - org.apache.flink.api.java.operators.translation.TupleRightUnwrappingJoiner<I1,I2,OUT,K> (implements org.apache.flink.api.common.functions.FlatJoinFunction<IN1,IN2,OUT>)
    - org.apache.flink.api.java.operators.translation.TupleUnwrappingJoiner<I1,I2,OUT,K> (implements org.apache.flink.api.common.functions.FlatJoinFunction<IN1,IN2,OUT>)
- org.apache.flink.api.java.operators.translation.CombineToGroupCombineWrapper<IN,OUT,F> (implements org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>, org.apache.flink.api.common.functions.GroupReduceFunction<T,O>)
- org.apache.flink.api.common.operators.Operator<OUT> (implements org.apache.flink.util.Visitable<T>)
  - org.apache.flink.api.common.operators.AbstractUdfOperator<OUT,FT>
    - org.apache.flink.api.common.operators.DualInputOperator<IN1,IN2,OUT,FT>
      - org.apache.flink.api.common.operators.base.CoGroupOperatorBase<IN1,IN2,OUT,FT>
        
        org.apache.flink.api.java.operators.translation.PlanBothUnwrappingCoGroupOperator<I1,I2,OUT,K>
        
        org.apache.flink.api.java.operators.translation.PlanLeftUnwrappingCoGroupOperator<I1,I2,OUT,K>
        
        org.apache.flink.api.java.operators.translation.PlanRightUnwrappingCoGroupOperator<I1,I2,OUT,K>
    - org.apache.flink.api.common.operators.SingleInputOperator<IN,OUT,FT>
      - org.apache.flink.api.common.operators.base.FilterOperatorBase<T,FT>
        
        org.apache.flink.api.java.operators.translation.PlanFilterOperator<T>
      - org.apache.flink.api.common.operators.base.GroupCombineOperatorBase<IN,OUT,FT>
        
        org.apache.flink.api.java.operators.translation.PlanUnwrappingGroupCombineOperator<IN,OUT,K>
        
        org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedGroupCombineOperator<IN,OUT,K1,K2>
      - org.apache.flink.api.common.operators.base.GroupReduceOperatorBase<IN,OUT,FT>
        
        org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceGroupOperator<IN,OUT,K>
        
        org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedReduceGroupOperator<IN,OUT,K1,K2>
      - org.apache.flink.api.common.operators.base.MapOperatorBase<IN,OUT,FT>
        
        org.apache.flink.api.java.operators.translation.PlanProjectOperator<T,R>
      - org.apache.flink.api.common.operators.base.ReduceOperatorBase<T,FT>
        
        org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceOperator<T,K>
- org.apache.flink.api.java.operators.translation.Tuple3UnwrappingIterator<T,K1,K2> (implements java.lang.Iterable<T>, java.util.Iterator<E>, java.io.Serializable)
- org.apache.flink.api.java.operators.translation.Tuple3WrappingCollector<IN,K1,K2> (implements org.apache.flink.util.Collector<T>, java.io.Serializable)
- org.apache.flink.api.java.operators.translation.TupleUnwrappingIterator<T,K> (implements java.lang.Iterable<T>, java.util.Iterator<E>, java.io.Serializable)
- org.apache.flink.api.java.operators.translation.TupleWrappingCollector<IN,K> (implements org.apache.flink.util.Collector<T>, java.io.Serializable)

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

Class Hierarchy