Class Hierarchy
- java.lang.Object
- org.apache.wayang.spark.mapping.CartesianMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.CoGroupMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.CollectionSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.CountMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.DistinctMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.DoWhileMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.FilterMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.FlatMapMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.GlobalMaterializedGroupMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.GlobalReduceMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.IntersectMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.JoinMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.KafkaTopicSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.KafkaTopicSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.LocalCallbackSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.LoopMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.MapMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.MapPartitionsMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.Mappings
- org.apache.wayang.spark.mapping.MaterializedGroupByMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.ObjectFileSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.ObjectFileSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.ParquetSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.ReduceByMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.RepeatMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.SampleMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.SortMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.TextFileSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.TextFileSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.UnionAllMapping (implements org.apache.wayang.core.mapping.Mapping)
- org.apache.wayang.spark.mapping.ZipWithIdMapping (implements org.apache.wayang.core.mapping.Mapping)