Hierarchy For Package org.apache.wayang.flink.operators

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.wayang.flink.operators.FlinkPageRankOperator.BuildOutgoingEdgeList (implements org.apache.flink.api.common.functions.GroupReduceFunction<T,O>)
  • org.apache.wayang.flink.operators.FlinkPageRankOperator.Dampener (implements org.apache.flink.api.common.functions.MapFunction<T,O>)
  • org.apache.wayang.flink.operators.FlinkPageRankOperator.EpsilonFilter (implements org.apache.flink.api.common.functions.FilterFunction<T>)
  • org.apache.wayang.flink.operators.FlinkPageRankOperator.JoinVertexWithEdgesMatch (implements org.apache.flink.api.common.functions.FlatMapFunction<T,O>)
  • org.apache.wayang.flink.operators.FlinkPageRankOperator.RankAssigner (implements org.apache.flink.api.common.functions.MapFunction<T,O>)
  • org.apache.wayang.core.plan.wayangplan.OperatorBase (implements org.apache.wayang.core.plan.wayangplan.Operator, java.io.Serializable)
    • org.apache.wayang.core.plan.wayangplan.BinaryToUnaryOperator<InputType0,InputType1,OutputType> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
      • org.apache.wayang.basic.operators.CartesianOperator<InputType0,InputType1>
        • org.apache.wayang.flink.operators.FlinkCartesianOperator<InputType0,InputType1> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.CoGroupOperator<InputType0,InputType1,Key>
        • org.apache.wayang.flink.operators.FlinkCoGroupOperator<InputType0,InputType1,TypeKey> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.IntersectOperator<Type>
        • org.apache.wayang.flink.operators.FlinkIntersectOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.JoinOperator<InputType0,InputType1,Key>
        • org.apache.wayang.flink.operators.FlinkJoinOperator<InputType0,InputType1,KeyType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.UnionAllOperator<Type>
        • org.apache.wayang.flink.operators.FlinkUnionAllOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
    • org.apache.wayang.basic.operators.DoWhileOperator<InputType,ConvergenceType> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator, org.apache.wayang.core.plan.wayangplan.LoopHeadOperator)
      • org.apache.wayang.flink.operators.FlinkDoWhileOperator<InputType,ConvergenceType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
    • org.apache.wayang.basic.operators.LoopOperator<InputType,ConvergenceType> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator, org.apache.wayang.core.plan.wayangplan.LoopHeadOperator)
      • org.apache.wayang.flink.operators.FlinkLoopOperator<InputType,ConvergenceType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
    • org.apache.wayang.basic.operators.RepeatOperator<Type> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator, org.apache.wayang.core.plan.wayangplan.LoopHeadOperator)
      • org.apache.wayang.flink.operators.FlinkRepeatExpandedOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.flink.operators.FlinkRepeatOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
    • org.apache.wayang.core.plan.wayangplan.UnarySink<T> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
      • org.apache.wayang.flink.operators.FlinkTsvFileSink<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.LocalCallbackSink<T>
        • org.apache.wayang.flink.operators.FlinkLocalCallbackSink<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.ObjectFileSink<T>
        • org.apache.wayang.flink.operators.FlinkObjectFileSink<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.TextFileSink<T>
        • org.apache.wayang.flink.operators.FlinkTextFileSink<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
    • org.apache.wayang.core.plan.wayangplan.UnarySource<T> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
      • org.apache.wayang.basic.operators.CollectionSource<T> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
        • org.apache.wayang.flink.operators.FlinkCollectionSource<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.ObjectFileSource<T>
        • org.apache.wayang.flink.operators.FlinkObjectFileSource<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.TextFileSource
        • org.apache.wayang.flink.operators.FlinkTextFileSource (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
    • org.apache.wayang.core.plan.wayangplan.UnaryToUnaryOperator<InputType,OutputType> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
      • org.apache.wayang.basic.operators.CountOperator<Type>
        • org.apache.wayang.flink.operators.FlinkCountOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.DistinctOperator<Type>
        • org.apache.wayang.flink.operators.FlinkDistinctOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.FilterOperator<Type>
        • org.apache.wayang.flink.operators.FlinkFilterOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.FlatMapOperator<InputType,OutputType>
        • org.apache.wayang.flink.operators.FlinkFlatMapOperator<InputType,OutputType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.flink.operators.FlinkCollectionSink<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.GlobalMaterializedGroupOperator<Type>
        • org.apache.wayang.flink.operators.FlinkGlobalMaterializedGroupOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.GlobalReduceOperator<Type>
        • org.apache.wayang.flink.operators.FlinkGlobalReduceOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.GroupByOperator<Input,Key>
        • org.apache.wayang.flink.operators.FlinkGroupByOperator<InputType,KeyType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.MapOperator<InputType,OutputType>
        • org.apache.wayang.flink.operators.FlinkMapOperator<InputType,OutputType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.MapPartitionsOperator<InputType,OutputType>
        • org.apache.wayang.flink.operators.FlinkMapPartitionsOperator<InputType,OutputType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.MaterializedGroupByOperator<Type,Key>
        • org.apache.wayang.flink.operators.FlinkMaterializedGroupByOperator<Type,KeyType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.PageRankOperator
        • org.apache.wayang.flink.operators.FlinkPageRankOperator (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.ReduceByOperator<Type,Key>
        • org.apache.wayang.flink.operators.FlinkReduceByOperator<InputType,KeyType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.SampleOperator<Type>
        • org.apache.wayang.flink.operators.FlinkSampleOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.SortOperator<Type,Key>
        • org.apache.wayang.flink.operators.FlinkSortOperator<InputType,KeyType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.basic.operators.ZipWithIdOperator<InputType>
        • org.apache.wayang.flink.operators.FlinkZipWithIdOperator<InputType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
  • com.esotericsoftware.kryo.Serializer<T>
    • org.apache.wayang.flink.operators.ScalaTupleSerializer
  • org.apache.flink.util.SplittableIterator<T> (implements java.util.Iterator<E>, java.io.Serializable)
    • org.apache.wayang.flink.operators.CollectionSplittableIterator<T> (implements java.io.Serializable)

Interface Hierarchy

• java.io.Serializable
  • org.apache.wayang.flink.operators.FlinkExecutionOperator (also extends org.apache.wayang.core.plan.wayangplan.ExecutionOperator)
  • org.apache.wayang.core.plan.wayangplan.Operator
    • org.apache.wayang.core.plan.wayangplan.ActualOperator
      • org.apache.wayang.core.plan.wayangplan.ElementaryOperator
        • org.apache.wayang.core.plan.wayangplan.ExecutionOperator
          • org.apache.wayang.flink.operators.FlinkExecutionOperator (also extends java.io.Serializable)