Class Hierarchy
- java.lang.Object
- org.apache.wayang.java.operators.JavaObjectFileSink.StreamChunker
- 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.java.operators.JavaCartesianOperator<InputType0,
InputType1> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaCartesianOperator<InputType0,
- org.apache.wayang.basic.operators.CoGroupOperator<InputType0,
InputType1, Key> - org.apache.wayang.java.operators.JavaCoGroupOperator<InputType0,
InputType1, KeyType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaCoGroupOperator<InputType0,
- org.apache.wayang.basic.operators.IntersectOperator<Type>
- org.apache.wayang.java.operators.JavaIntersectOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.JoinOperator<InputType0,
InputType1, Key> - org.apache.wayang.java.operators.JavaJoinOperator<InputType0,
InputType1, KeyType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaJoinOperator<InputType0,
- org.apache.wayang.basic.operators.UnionAllOperator<Type>
- org.apache.wayang.java.operators.JavaUnionAllOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- 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.java.operators.JavaDoWhileOperator<InputType,
ConvergenceType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaDoWhileOperator<InputType,
- 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.java.operators.JavaLoopOperator<InputType,
ConvergenceType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaLoopOperator<InputType,
- 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.java.operators.JavaRepeatOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.core.plan.wayangplan.UnarySink<T> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
- org.apache.wayang.java.operators.JavaTsvFileSink<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.KafkaTopicSink<T> (implements java.io.Serializable)
- org.apache.wayang.java.operators.JavaKafkaTopicSink<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.LocalCallbackSink<T>
- org.apache.wayang.java.operators.JavaLocalCallbackSink<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.ObjectFileSink<T>
- org.apache.wayang.java.operators.JavaObjectFileSink<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.TextFileSink<T>
- org.apache.wayang.java.operators.JavaTextFileSink<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- 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.java.operators.JavaAmazonS3Source (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.AzureBlobStorageSource
- org.apache.wayang.java.operators.JavaAzureBlobStorageSource (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.CollectionSource<T> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
- org.apache.wayang.java.operators.JavaCollectionSource<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.GoogleCloudStorageSource
- org.apache.wayang.java.operators.JavaGoogleCloudStorageSource (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaTsvFileSource<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.KafkaTopicSource
- org.apache.wayang.java.operators.JavaKafkaTopicSource (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.ObjectFileSource<T>
- org.apache.wayang.java.operators.JavaObjectFileSource<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.ParquetSource
- org.apache.wayang.java.operators.JavaParquetSource (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.TextFileSource
- org.apache.wayang.java.operators.JavaTextFileSource (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.AmazonS3Source
- 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.java.operators.JavaCountOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.DistinctOperator<Type>
- org.apache.wayang.java.operators.JavaDistinctOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.FilterOperator<Type>
- org.apache.wayang.java.operators.JavaFilterOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.FlatMapOperator<InputType,
OutputType> - org.apache.wayang.java.operators.JavaFlatMapOperator<InputType,
OutputType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaFlatMapOperator<InputType,
- org.apache.wayang.basic.operators.GlobalMaterializedGroupOperator<Type>
- org.apache.wayang.java.operators.JavaGlobalMaterializedGroupOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.GlobalReduceOperator<Type>
- org.apache.wayang.java.operators.JavaGlobalReduceOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaCollectOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.MapOperator<InputType,
OutputType> - org.apache.wayang.java.operators.JavaMapOperator<InputType,
OutputType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaMapOperator<InputType,
- org.apache.wayang.basic.operators.MapPartitionsOperator<InputType,
OutputType> - org.apache.wayang.java.operators.JavaMapPartitionsOperator<InputType,
OutputType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaMapPartitionsOperator<InputType,
- org.apache.wayang.basic.operators.MaterializedGroupByOperator<Type,
Key> - org.apache.wayang.java.operators.JavaMaterializedGroupByOperator<Type,
KeyType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaMaterializedGroupByOperator<Type,
- org.apache.wayang.basic.operators.ReduceByOperator<Type,
Key> - org.apache.wayang.java.operators.JavaReduceByOperator<Type,
KeyType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaReduceByOperator<Type,
- org.apache.wayang.basic.operators.SampleOperator<Type>
- org.apache.wayang.java.operators.JavaRandomSampleOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaReservoirSampleOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.basic.operators.SortOperator<Type,
Key> - org.apache.wayang.java.operators.JavaSortOperator<Type,
Key> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
- org.apache.wayang.java.operators.JavaSortOperator<Type,
- org.apache.wayang.basic.operators.CountOperator<Type>
- org.apache.wayang.core.plan.wayangplan.BinaryToUnaryOperator<InputType0,
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.java.operators.JavaExecutionOperator
- org.apache.wayang.core.plan.wayangplan.ExecutionOperator
- org.apache.wayang.core.plan.wayangplan.ElementaryOperator
- org.apache.wayang.core.plan.wayangplan.ActualOperator
- org.apache.wayang.core.plan.wayangplan.Operator