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

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • 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.spark.operators.SparkCartesianOperator<InputType0,InputType1> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.CoGroupOperator<InputType0,InputType1,Key>
        • org.apache.wayang.spark.operators.SparkCoGroupOperator<In0,In1,Key> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.IntersectOperator<Type>
        • org.apache.wayang.spark.operators.SparkIntersectOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.JoinOperator<InputType0,InputType1,Key>
        • org.apache.wayang.spark.operators.SparkJoinOperator<InputType0,InputType1,KeyType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.UnionAllOperator<Type>
        • org.apache.wayang.spark.operators.SparkUnionAllOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • 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.spark.operators.SparkDoWhileOperator<InputType,ConvergenceType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • 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.spark.operators.SparkLoopOperator<InputType,ConvergenceType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • 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.spark.operators.SparkRepeatOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • org.apache.wayang.core.plan.wayangplan.UnarySink<T> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
      • org.apache.wayang.basic.operators.KafkaTopicSink<T> (implements java.io.Serializable)
        • org.apache.wayang.spark.operators.SparkKafkaTopicSink<T> (implements java.io.Serializable, org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.LocalCallbackSink<T>
        • org.apache.wayang.spark.operators.SparkLocalCallbackSink<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.ObjectFileSink<T>
        • org.apache.wayang.spark.operators.SparkObjectFileSink<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.spark.operators.SparkTsvFileSink<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.TextFileSink<T>
        • org.apache.wayang.spark.operators.SparkTextFileSink<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • 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.spark.operators.SparkCollectionSource<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.KafkaTopicSource
        • org.apache.wayang.spark.operators.SparkKafkaTopicSource (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.ObjectFileSource<T>
        • org.apache.wayang.spark.operators.SparkObjectFileSource<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.ParquetSource
        • org.apache.wayang.spark.operators.SparkParquetSource (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.spark.operators.SparkTsvFileSource<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.TextFileSource
        • org.apache.wayang.spark.operators.SparkTextFileSource (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • 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.spark.operators.SparkCountOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.DistinctOperator<Type>
        • org.apache.wayang.spark.operators.SparkDistinctOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.FilterOperator<Type>
        • org.apache.wayang.spark.operators.SparkFilterOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.FlatMapOperator<InputType,OutputType>
        • org.apache.wayang.spark.operators.SparkFlatMapOperator<InputType,OutputType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.GlobalMaterializedGroupOperator<Type>
        • org.apache.wayang.spark.operators.SparkGlobalMaterializedGroupOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.GlobalReduceOperator<Type>
        • org.apache.wayang.spark.operators.SparkGlobalReduceOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.MapOperator<InputType,OutputType>
        • org.apache.wayang.spark.operators.SparkMapOperator<InputType,OutputType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.MapPartitionsOperator<InputType,OutputType>
        • org.apache.wayang.spark.operators.SparkMapPartitionsOperator<InputType,OutputType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.MaterializedGroupByOperator<Type,Key>
        • org.apache.wayang.spark.operators.SparkMaterializedGroupByOperator<Type,KeyType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.ReduceByOperator<Type,Key>
        • org.apache.wayang.spark.operators.SparkReduceByOperator<Type,KeyType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.SampleOperator<Type>
        • org.apache.wayang.spark.operators.SparkBernoulliSampleOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
        • org.apache.wayang.spark.operators.SparkRandomPartitionSampleOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
        • org.apache.wayang.spark.operators.SparkShufflePartitionSampleOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.SortOperator<Type,Key>
        • org.apache.wayang.spark.operators.SparkSortOperator<Type,Key> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.spark.operators.SparkBroadcastOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.spark.operators.SparkCacheOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.spark.operators.SparkCollectOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.ZipWithIdOperator<InputType>
        • org.apache.wayang.spark.operators.SparkZipWithIdOperator<InputType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)

Interface Hierarchy

• java.io.Serializable
  • 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.spark.operators.SparkExecutionOperator