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

Package Hierarchies:

• All Packages

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.java.operators.translation.PlanProjectOperator.MapProjector<T,R> (implements org.apache.flink.api.common.functions.MapFunction<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.PlanBothUnwrappingCoGroupOperator.TupleBothUnwrappingCoGrouper<I1,I2,OUT,K> (implements org.apache.flink.api.common.functions.CoGroupFunction<IN1,IN2,O>)
      • 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.PlanLeftUnwrappingCoGroupOperator.TupleLeftUnwrappingCoGrouper<I1,I2,OUT,K> (implements org.apache.flink.api.common.functions.CoGroupFunction<IN1,IN2,O>)
      • org.apache.flink.api.java.operators.translation.PlanRightUnwrappingCoGroupOperator.TupleRightUnwrappingCoGrouper<I1,I2,OUT,K> (implements org.apache.flink.api.common.functions.CoGroupFunction<IN1,IN2,O>)
      • org.apache.flink.api.java.operators.translation.PlanUnwrappingGroupCombineOperator.TupleUnwrappingGroupCombiner<IN,OUT,K> (implements org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>)
      • org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer<IN,OUT,K> (implements org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>, org.apache.flink.api.common.functions.GroupReduceFunction<T,O>)
      • org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceGroupOperator.TupleUnwrappingNonCombinableGroupReducer<IN,OUT,K> (implements org.apache.flink.api.common.functions.GroupReduceFunction<T,O>)
      • org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceOperator.ReduceWrapper<T,K> (implements org.apache.flink.api.common.functions.ReduceFunction<T>)
      • org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedGroupCombineOperator.TupleUnwrappingGroupReducer<IN,OUT,K1,K2> (implements org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>)
      • org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer<IN,OUT,K1,K2> (implements org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>, org.apache.flink.api.common.functions.GroupReduceFunction<T,O>)
      • org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingNonCombinableGroupReducer<IN,OUT,K1,K2> (implements org.apache.flink.api.common.functions.GroupReduceFunction<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)