Class Hierarchy
- java.lang.Object
- org.apache.wayang.basic.operators.AmazonS3Source.CardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
- org.apache.wayang.basic.operators.AzureBlobStorageSource.CardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
- org.apache.wayang.basic.operators.DLTrainingOperator.Option
- org.apache.wayang.basic.operators.GoogleCloudStorageSource.CardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
- 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.DecisionTreeRegressionOperator
- 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.LinearSVCOperator
- org.apache.wayang.basic.operators.LogisticRegressionOperator
- 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.CartesianOperator<InputType0,
- 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.AmazonS3Source
- org.apache.wayang.basic.operators.AzureBlobStorageSource
- org.apache.wayang.basic.operators.CollectionSource<T> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
- org.apache.wayang.basic.operators.GoogleCloudStorageSource
- org.apache.wayang.basic.operators.KafkaTopicSource
- org.apache.wayang.basic.operators.ObjectFileSource<T>
- org.apache.wayang.basic.operators.ParquetSource
- 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,
- org.apache.wayang.basic.operators.ParquetSource.CardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
- org.apache.wayang.basic.operators.PredictOperators
- org.apache.wayang.basic.operators.TextFileSource.CardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
Enum Class Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
- org.apache.wayang.basic.operators.SampleOperator.Methods
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)