StreamedMapMapping (Apache Wayang 1.1.1 API)

java.lang.Object

org.apache.wayang.flink.mapping.StreamedMapMapping

All Implemented Interfaces:: Mapping

public class StreamedMapMapping extends Object implements Mapping

Mapping from MapOperator to FlinkDataStreamMapOperator.

Constructor Summary

Constructors

Constructor

Description

StreamedMapMapping()
Method Summary

Modifier and Type

Method

Description

Collection<PlanTransformation>

getTransformations()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- StreamedMapMapping
  
  public StreamedMapMapping()
Method Details
- getTransformations
  
  public Collection<PlanTransformation> getTransformations()
  
  Specified by:
  
  getTransformations in interface Mapping
  
  Returns:
  
  the transformations that make up this mapping