Hierarchy For Package org.apache.flink.api.common.operators.base

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.common.operators.base.BulkIterationBase.TerminationCriterionMapper<X> (implements org.apache.flink.api.common.functions.FlatMapFunction<T,O>)
  • org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregationConvergence (implements org.apache.flink.api.common.aggregators.ConvergenceCriterion<T>)
  • org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregator (implements org.apache.flink.api.common.aggregators.Aggregator<T>)
  • org.apache.flink.api.common.operators.base.CoGroupRawOperatorBase.SimpleListIterable<IN> (implements java.lang.Iterable<T>)
  • org.apache.flink.api.common.operators.base.CoGroupRawOperatorBase.SimpleListIterable.SimpleListIterator<IN> (implements java.util.Iterator<E>)
  • 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.common.operators.base.CoGroupRawOperatorBase<IN1,IN2,OUT,FT>
        • org.apache.flink.api.common.operators.base.CrossOperatorBase<IN1,IN2,OUT,FT>
        • org.apache.flink.api.common.operators.base.DeltaIterationBase<ST,WT> (implements org.apache.flink.api.common.operators.IterationOperator)
        • org.apache.flink.api.common.operators.base.JoinOperatorBase<IN1,IN2,OUT,FT>
          • org.apache.flink.api.common.operators.base.InnerJoinOperatorBase<IN1,IN2,OUT,FT>
          • org.apache.flink.api.common.operators.base.OuterJoinOperatorBase<IN1,IN2,OUT,FT>
      • org.apache.flink.api.common.operators.SingleInputOperator<IN,OUT,FT>
        • org.apache.flink.api.common.operators.base.BulkIterationBase<T> (implements org.apache.flink.api.common.operators.IterationOperator)
        • org.apache.flink.api.common.operators.base.FilterOperatorBase<T,FT>
        • org.apache.flink.api.common.operators.base.FlatMapOperatorBase<IN,OUT,FT>
        • org.apache.flink.api.common.operators.base.GroupCombineOperatorBase<IN,OUT,FT>
        • org.apache.flink.api.common.operators.base.GroupReduceOperatorBase<IN,OUT,FT>
        • org.apache.flink.api.common.operators.base.MapOperatorBase<IN,OUT,FT>
        • org.apache.flink.api.common.operators.base.MapPartitionOperatorBase<IN,OUT,FT>
        • org.apache.flink.api.common.operators.base.PartitionOperatorBase<IN>
        • org.apache.flink.api.common.operators.base.ReduceOperatorBase<T,FT>
        • org.apache.flink.api.common.operators.base.SortPartitionOperatorBase<IN>
    • org.apache.flink.api.common.operators.base.BulkIterationBase.PartialSolutionPlaceHolder<OT>
    • org.apache.flink.api.common.operators.base.DeltaIterationBase.SolutionSetPlaceHolder<ST>
    • org.apache.flink.api.common.operators.base.DeltaIterationBase.WorksetPlaceHolder<WT>

Interface Hierarchy

• org.apache.flink.api.common.operators.base.CrossOperatorBase.CrossWithLarge
• org.apache.flink.api.common.operators.base.CrossOperatorBase.CrossWithSmall

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.api.common.operators.base.CrossOperatorBase.CrossHint
    • org.apache.flink.api.common.operators.base.JoinOperatorBase.JoinHint
    • org.apache.flink.api.common.operators.base.OuterJoinOperatorBase.OuterJoinType
    • org.apache.flink.api.common.operators.base.PartitionOperatorBase.PartitionMethod
    • org.apache.flink.api.common.operators.base.ReduceOperatorBase.CombineHint