Package org.apache.wayang.flink.platform

Class FlinkPlatform

java.lang.Object

org.apache.wayang.core.platform.Platform

org.apache.wayang.flink.platform.FlinkPlatform

public class FlinkPlatform
extends Platform

Platform for Apache Flink.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	INITIALIZATION_MS_CONFIG_KEY

Fields inherited from class org.apache.wayang.core.platform.Platform

jsonSerializer

Method Summary

Modifier and Type	Method	Description
void	configureDefaults(Configuration configuration)	Configure default settings for this instance, e.g., to be able to create LoadProfileToTimeConverters.
LoadProfileToTimeConverter	createLoadProfileToTimeConverter(Configuration configuration)
TimeToCostConverter	createTimeToCostConverter(Configuration configuration)	Creates a TimeToCostConverter for this instance.
Executor.Factory	getExecutorFactory()
FlinkContextReference	getFlinkContext(Job job)	Configures the single maintained ExecutionEnvironment according to the job and returns it.
static FlinkPlatform	getInstance()

Methods inherited from class org.apache.wayang.core.platform.Platform

createExecutor, getConfigurationName, getInitializeMillis, getName, isSinglePlatformExecutionPossible, load, toString, warmUp

Methods inherited from class java.lang.Object

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

Field Detail

INITIALIZATION_MS_CONFIG_KEY

public static final java.lang.String INITIALIZATION_MS_CONFIG_KEY

See Also:

Constant Field Values

Method Detail

getInstance

public static FlinkPlatform getInstance()

getFlinkContext

public FlinkContextReference getFlinkContext(Job job)

Configures the single maintained ExecutionEnvironment according to the job and returns it.

Returns:

a FlinkContextReference wrapping the ExecutionEnvironment

configureDefaults

public void configureDefaults(Configuration configuration)

Description copied from class: Platform

Configure default settings for this instance, e.g., to be able to create LoadProfileToTimeConverters.

Specified by:

configureDefaults in class Platform

Parameters:

configuration - that should be configured

getExecutorFactory

public Executor.Factory getExecutorFactory()

Specified by:

getExecutorFactory in class Platform

createLoadProfileToTimeConverter

public LoadProfileToTimeConverter createLoadProfileToTimeConverter(Configuration configuration)

Specified by:

createLoadProfileToTimeConverter in class Platform

Returns:

a default LoadProfileToTimeConverter

createTimeToCostConverter

public TimeToCostConverter createTimeToCostConverter(Configuration configuration)

Description copied from class: Platform

Creates a TimeToCostConverter for this instance.

Specified by:

createTimeToCostConverter in class Platform

Parameters:

configuration - configures the TimeToCostConverter

Returns:

the TimeToCostConverter