Package org.apache.wayang.flink.mapping

Class Summary

Class	Description
CartesianMapping	Mapping from CartesianOperator to FlinkCartesianOperator.
CoGroupMapping	Mapping from CoGroupOperator to FlinkCoGroupOperator.
CollectionSourceMapping	Mapping from CollectionSource to FlinkCollectionSource.
CountMapping	Mapping from CountOperator to FlinkCountOperator.
DistinctMapping	Mapping from DistinctOperator to FlinkDistinctOperator.
DoWhileMapping	Mapping from DoWhileOperator to FlinkDoWhileOperator.
FilterMapping	Mapping from FilterOperator to FlinkFilterOperator.
FlatMapMapping	Mapping from FlatMapOperator to FlinkFlatMapOperator.
GlobalMaterializedGroupMapping	Mapping from GlobalMaterializedGroupOperator to FlinkGlobalMaterializedGroupOperator.
GlobalReduceMapping	Mapping from GlobalReduceOperator to FlinkGlobalReduceOperator.
GroupByMapping	Mapping from GroupByOperator to FlinkGroupByOperator.
IntersectMapping	Mapping from IntersectOperator to FlinkIntersectOperator.
JoinMapping	Mapping from JoinOperator to FlinkJoinOperator.
LocalCallbackSinkMapping	Mapping from LocalCallbackSink to FlinkLocalCallbackSink.
LoopMapping	Mapping from LoopOperator to FlinkLoopOperator.
MapMapping	Mapping from MapOperator to FlinkMapOperator.
MapPartitionsMapping	Mapping from MapPartitionsOperator to FlinkMapPartitionsOperator.
Mappings	Register for Mappings for this platform.
MaterializedGroupByMapping	Mapping from MaterializedGroupByOperator to FlinkMaterializedGroupByOperator.
ObjectFileSinkMapping	Mapping from ObjectFileSink to FlinkObjectFileSink.
ObjectFileSourceMapping	Mapping from ObjectFileSource to FlinkObjectFileSource.
PageRankMapping	Mapping from PageRankOperator to FlinkPageRankOperator.
ReduceByMapping	Mapping from ReduceByOperator to FlinkReduceByOperator.
RepeatMapping	Mapping from RepeatOperator to FlinkRepeatOperator.
SampleMapping	Mapping from SampleOperator to FlinkSampleOperator.
SortMapping	Mapping from SortOperator to FlinkSortOperator.
TextFileSinkMapping	Mapping from TextFileSink to FlinkTextFileSink.
TextFileSourceMapping	Mapping from TextFileSource to FlinkTextFileSource.
UnionAllMapping	Mapping from UnionAllOperator to FlinkUnionAllOperator.
ZipWithIdMapping	Mapping from ZipWithIdOperator to FlinkZipWithIdOperator.