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

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.functions.RichFlatJoinFunction<IN1,IN2,OUT> (implements org.apache.flink.api.common.functions.FlatJoinFunction<IN1,IN2,OUT>)
      • org.apache.flink.api.java.operators.JoinOperator.DefaultFlatJoinFunction<T1,T2>
      • org.apache.flink.api.java.operators.JoinOperator.ProjectFlatJoinFunction<T1,T2,R>
    • org.apache.flink.api.common.functions.RichGroupReduceFunction<IN,OUT> (implements org.apache.flink.api.common.functions.GroupReduceFunction<T,O>)
      • org.apache.flink.api.java.operators.AggregateOperator.AggregatingUdf<T> (implements org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>)
    • org.apache.flink.api.java.operators.translation.WrappingFunction<T>
      • org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.WrappingFlatJoinFunction<IN1,IN2,OUT> (implements org.apache.flink.api.common.functions.FlatJoinFunction<IN1,IN2,OUT>)
  • org.apache.flink.api.java.operators.CoGroupOperator.CoGroupOperatorSets<I1,I2>
  • org.apache.flink.api.java.operators.CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate
  • org.apache.flink.api.java.operators.CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction
  • org.apache.flink.api.java.operators.CrossOperator.CrossProjection<I1,I2>
  • org.apache.flink.api.java.operators.CrossOperator.DefaultCrossFunction<T1,T2> (implements org.apache.flink.api.common.functions.CrossFunction<IN1,IN2,OUT>)
  • org.apache.flink.api.java.operators.CrossOperator.ProjectCrossFunction<T1,T2,R> (implements org.apache.flink.api.common.functions.CrossFunction<IN1,IN2,OUT>)
  • org.apache.flink.api.java.DataSet<T>
    • org.apache.flink.api.java.operators.BulkIterationResultSet<T>
    • org.apache.flink.api.java.operators.DeltaIteration.SolutionSetPlaceHolder<ST>
    • org.apache.flink.api.java.operators.DeltaIteration.WorksetPlaceHolder<WT>
    • org.apache.flink.api.java.operators.DeltaIterationResultSet<ST,WT>
    • org.apache.flink.api.java.operators.Operator<OUT,O>
      • org.apache.flink.api.java.operators.DataSource<OUT>
      • org.apache.flink.api.java.operators.SingleInputOperator<IN,OUT,O>
        • org.apache.flink.api.java.operators.AggregateOperator<IN>
        • org.apache.flink.api.java.operators.DistinctOperator<T>
        • org.apache.flink.api.java.operators.IterativeDataSet<T>
        • org.apache.flink.api.java.operators.PartitionOperator<T>
        • org.apache.flink.api.java.operators.ProjectOperator<IN,OUT>
        • org.apache.flink.api.java.operators.SingleInputUdfOperator<IN,OUT,O> (implements org.apache.flink.api.java.operators.UdfOperator<O>)
          • org.apache.flink.api.java.operators.FilterOperator<T>
          • org.apache.flink.api.java.operators.FlatMapOperator<IN,OUT>
          • org.apache.flink.api.java.operators.GroupCombineOperator<IN,OUT>
          • org.apache.flink.api.java.operators.GroupReduceOperator<IN,OUT>
          • org.apache.flink.api.java.operators.MapOperator<IN,OUT>
          • org.apache.flink.api.java.operators.MapPartitionOperator<IN,OUT>
          • org.apache.flink.api.java.operators.ReduceOperator<IN>
        • org.apache.flink.api.java.operators.SortPartitionOperator<T>
      • org.apache.flink.api.java.operators.TwoInputOperator<IN1,IN2,OUT,O>
        • org.apache.flink.api.java.operators.TwoInputUdfOperator<IN1,IN2,OUT,O> (implements org.apache.flink.api.java.operators.UdfOperator<O>)
          • org.apache.flink.api.java.operators.CoGroupOperator<I1,I2,OUT>
          • org.apache.flink.api.java.operators.CoGroupRawOperator<I1,I2,OUT>
          • org.apache.flink.api.java.operators.CrossOperator<I1,I2,OUT>
            • org.apache.flink.api.java.operators.CrossOperator.DefaultCross<I1,I2>
            • org.apache.flink.api.java.operators.CrossOperator.ProjectCross<I1,I2,OUT>
          • org.apache.flink.api.java.operators.JoinOperator<I1,I2,OUT>
            • org.apache.flink.api.java.operators.JoinOperator.EquiJoin<I1,I2,OUT>
              • org.apache.flink.api.java.operators.JoinOperator.DefaultJoin<I1,I2> (implements org.apache.flink.api.java.operators.join.JoinFunctionAssigner<I1,I2>)
              • org.apache.flink.api.java.operators.JoinOperator.ProjectJoin<I1,I2,OUT>
        • org.apache.flink.api.java.operators.UnionOperator<T>
  • org.apache.flink.api.java.operators.DataSink<T>
  • org.apache.flink.api.java.operators.DeltaIteration<ST,WT>
  • org.apache.flink.api.java.operators.DistinctOperator.DistinctFunction<T> (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.Grouping<T>
    • org.apache.flink.api.java.operators.SortedGrouping<T>
    • org.apache.flink.api.java.operators.UnsortedGrouping<T>
  • org.apache.flink.api.java.operators.JoinOperator.JoinProjection<I1,I2>
  • org.apache.flink.api.java.operators.join.JoinOperatorSetsBase<I1,I2>
    • org.apache.flink.api.java.operators.JoinOperator.JoinOperatorSets<I1,I2>
  • org.apache.flink.api.java.operators.join.JoinOperatorSetsBase.JoinOperatorSetsPredicateBase
    • org.apache.flink.api.java.operators.JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate
  • org.apache.flink.api.java.operators.KeyFunctions
  • org.apache.flink.api.java.operators.OperatorTranslation
  • org.apache.flink.api.java.operators.ProjectOperator.Projection<T>
  • org.apache.flink.api.java.operators.UdfOperatorUtils

Interface Hierarchy

• org.apache.flink.api.java.operators.CustomUnaryOperation<IN,OUT>
• org.apache.flink.api.java.operators.UdfOperator<O>