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.DualInputOperator<IN1,IN2,OUT,FT>
- 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>
- org.apache.flink.api.common.operators.AbstractUdfOperator<OUT,FT>
- org.apache.flink.api.common.functions.AbstractRichFunction (implements org.apache.flink.api.common.functions.RichFunction, java.io.Serializable)
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
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)