Package org.apache.wayang.spark.mapping

Class Summary

Class	Description
CartesianMapping	Mapping from CartesianOperator to SparkCartesianOperator.
CoGroupMapping	Mapping from CoGroupOperator to SparkCoGroupOperator.
CollectionSourceMapping	Mapping from CollectionSource to SparkCollectionSource.
CountMapping	Mapping from CountOperator to SparkCountOperator.
DistinctMapping	Mapping from DistinctOperator to SparkDistinctOperator.
DoWhileMapping	Mapping from LoopOperator to SparkLoopOperator.
FilterMapping	Mapping from FilterOperator to SparkFilterOperator.
FlatMapMapping	Mapping from FlatMapOperator to SparkFlatMapOperator.
GlobalMaterializedGroupMapping	Mapping from GlobalMaterializedGroupOperator to SparkGlobalMaterializedGroupOperator.
GlobalReduceMapping	Mapping from GlobalReduceOperator to SparkGlobalReduceOperator.
IntersectMapping	Mapping from IntersectOperator to SparkIntersectOperator.
JoinMapping	Mapping from JoinOperator to SparkJoinOperator.
KafkaTopicSinkMapping	Mapping from KafkaTopicSink to SparkKafkaTopicSink.
KafkaTopicSourceMapping	Mapping from KafkaTopicSource to SparkKafkaTopicSource.
LocalCallbackSinkMapping	Mapping from LocalCallbackSink to SparkLocalCallbackSink.
LoopMapping	Mapping from LoopOperator to SparkLoopOperator.
MapMapping	Mapping from MapOperator to SparkMapOperator.
MapPartitionsMapping	Mapping from MapPartitionsOperator to SparkMapPartitionsOperator.
Mappings	Register for Mappings for this platform.
MaterializedGroupByMapping	Mapping from MaterializedGroupByOperator to SparkMaterializedGroupByOperator.
ObjectFileSinkMapping	Mapping from ObjectFileSink to SparkObjectFileSink.
ObjectFileSourceMapping	Mapping from ObjectFileSource to SparkObjectFileSource.
ReduceByMapping	Mapping from ReduceByOperator to SparkReduceByOperator.
RepeatMapping	Mapping from RepeatOperator to SparkRepeatOperator.
SampleMapping	Mapping from SampleOperator to SparkRandomPartitionSampleOperator.
SortMapping	Mapping from SortOperator to SparkSortOperator.
TextFileSinkMapping	Mapping from CollectionSource to SparkCollectionSource.
TextFileSourceMapping	Mapping from CollectionSource to SparkCollectionSource.
UnionAllMapping	Mapping from UnionAllOperator to SparkUnionAllOperator.
ZipWithIdMapping	Mapping from ZipWithIdOperator to SparkZipWithIdOperator.