Package org.apache.wayang.flink.mapping

Class Mappings

java.lang.Object

org.apache.wayang.flink.mapping.Mappings

public class Mappings
extends Object

Register for Mappings for FlinkBasicPlugin.

Field Summary

Fields

Modifier and Type	Field	Description
static final Collection<Mapping>	BASIC_MAPPINGS	Deprecated. DataSet API in Flink has been deprecated move over to bounded streams for a 1-to-1 replacement BOUNDED_STREAM_MAPPINGS.
static final Collection<Mapping>	BOUNDED_STREAM_MAPPINGS

Constructor Summary

Constructors

Constructor	Description
Mappings()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

BASIC_MAPPINGS

public static final Collection<Mapping> BASIC_MAPPINGS

Deprecated.

DataSet API in Flink has been deprecated move over to bounded streams for a 1-to-1 replacement BOUNDED_STREAM_MAPPINGS.

Mappings using Flink's DataSets

BOUNDED_STREAM_MAPPINGS

public static final Collection<Mapping> BOUNDED_STREAM_MAPPINGS

Constructor Details

Mappings

public Mappings()