StreamedLocalCallbackSinkMapping (Apache Wayang 1.1.1 API)

java.lang.Object

org.apache.wayang.flink.mapping.StreamedLocalCallbackSinkMapping

All Implemented Interfaces:: Mapping

public class StreamedLocalCallbackSinkMapping extends Object implements Mapping

Constructor Summary

Constructors

Constructor

Description

StreamedLocalCallbackSinkMapping()
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
- StreamedLocalCallbackSinkMapping
  
  public StreamedLocalCallbackSinkMapping()
Method Details
- getTransformations
  
  public Collection<PlanTransformation> getTransformations()
  
  Specified by:
  
  getTransformations in interface Mapping
  
  Returns:
  
  the transformations that make up this mapping