Package org.apache.wayang.spark.mapping
package org.apache.wayang.spark.mapping
-
ClassesClassDescriptionMapping from
CartesianOperator
toSparkCartesianOperator
.Mapping fromCoGroupOperator
toSparkCoGroupOperator
.Mapping fromCollectionSource
toSparkCollectionSource
.Mapping fromCountOperator
toSparkCountOperator
.Mapping fromDistinctOperator
toSparkDistinctOperator
.Mapping fromLoopOperator
toSparkLoopOperator
.Mapping fromFilterOperator
toSparkFilterOperator
.Mapping fromFlatMapOperator
toSparkFlatMapOperator
.Mapping fromGlobalMaterializedGroupOperator
toSparkGlobalMaterializedGroupOperator
.Mapping fromGlobalReduceOperator
toSparkGlobalReduceOperator
.Mapping fromIntersectOperator
toSparkIntersectOperator
.Mapping fromJoinOperator
toSparkJoinOperator
.Mapping fromKafkaTopicSink
toSparkKafkaTopicSink
.Mapping fromKafkaTopicSource
toSparkKafkaTopicSource
.Mapping fromLocalCallbackSink
toSparkLocalCallbackSink
.Mapping fromLoopOperator
toSparkLoopOperator
.Mapping fromMapOperator
toSparkMapOperator
.Mapping fromMapPartitionsOperator
toSparkMapPartitionsOperator
.Register forMapping
s for this platform.Mapping fromMaterializedGroupByOperator
toSparkMaterializedGroupByOperator
.Mapping fromObjectFileSink
toSparkObjectFileSink
.Mapping fromObjectFileSource
toSparkObjectFileSource
.Mapping fromCollectionSource
toSparkCollectionSource
.Mapping fromReduceByOperator
toSparkReduceByOperator
.Mapping fromRepeatOperator
toSparkRepeatOperator
.Mapping fromSampleOperator
toSparkRandomPartitionSampleOperator
.Mapping fromSortOperator
toSparkSortOperator
.Mapping fromCollectionSource
toSparkCollectionSource
.Mapping fromCollectionSource
toSparkCollectionSource
.Mapping fromUnionAllOperator
toSparkUnionAllOperator
.Mapping fromZipWithIdOperator
toSparkZipWithIdOperator
.