Class Hierarchy
- java.lang.Object
- org.apache.wayang.basic.operators.DLTrainingOperator.Option
- org.apache.wayang.basic.operators.KafkaTopicSource.CardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
- org.apache.wayang.basic.operators.ObjectFileSource.CardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
- 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.basic.operators.CoGroupOperator<InputType0,InputType1,Key>
- org.apache.wayang.basic.operators.DecisionTreeClassificationOperator
- org.apache.wayang.basic.operators.DLTrainingOperator<X,Y>
- org.apache.wayang.basic.operators.IntersectOperator<Type>
- org.apache.wayang.basic.operators.JoinOperator<InputType0,InputType1,Key>
- org.apache.wayang.basic.operators.LinearRegressionOperator
- org.apache.wayang.basic.operators.ModelTransformOperator<X,Y>
- org.apache.wayang.basic.operators.PredictOperator<X,Y>
- org.apache.wayang.basic.operators.UnionAllOperator<Type>
- 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.basic.operators.LoopOperator<InputType,ConvergenceType> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator, org.apache.wayang.core.plan.wayangplan.LoopHeadOperator)
- 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.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.basic.operators.LocalCallbackSink<T>
- org.apache.wayang.basic.operators.ObjectFileSink<T>
- org.apache.wayang.basic.operators.TextFileSink<T>
- 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.basic.operators.KafkaTopicSource
- org.apache.wayang.basic.operators.ObjectFileSource<T>
- org.apache.wayang.basic.operators.TableSource
- org.apache.wayang.basic.operators.TextFileSource
- 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.basic.operators.DistinctOperator<Type>
- org.apache.wayang.basic.operators.FilterOperator<Type>
- org.apache.wayang.basic.operators.FlatMapOperator<InputType,OutputType>
- org.apache.wayang.basic.operators.GlobalMaterializedGroupOperator<Type>
- org.apache.wayang.basic.operators.GlobalReduceOperator<Type>
- org.apache.wayang.basic.operators.GroupByOperator<Input,Key>
- org.apache.wayang.basic.operators.KMeansOperator
- org.apache.wayang.basic.operators.MapOperator<InputType,OutputType>
- org.apache.wayang.basic.operators.MapPartitionsOperator<InputType,OutputType>
- org.apache.wayang.basic.operators.MaterializedGroupByOperator<Type,Key>
- org.apache.wayang.basic.operators.PageRankOperator
- org.apache.wayang.basic.operators.PyWayangReduceByOperator<Type,Key>
- org.apache.wayang.basic.operators.ReduceByOperator<Type,Key>
- org.apache.wayang.basic.operators.ReduceOperator<Type>
- org.apache.wayang.basic.operators.SampleOperator<Type>
- org.apache.wayang.basic.operators.SortOperator<Type,Key>
- org.apache.wayang.basic.operators.ZipWithIdOperator<InputType>
- org.apache.wayang.core.plan.wayangplan.BinaryToUnaryOperator<InputType0,InputType1,OutputType> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
- org.apache.wayang.basic.operators.PredictOperators
- org.apache.wayang.basic.operators.TextFileSource.CardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
- org.apache.wayang.basic.operators.SampleOperator.Methods
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)