Package org.apache.wayang.flink.platform
Class FlinkPlatform
java.lang.Object
org.apache.wayang.core.platform.Platform
org.apache.wayang.flink.platform.FlinkPlatform
Platform
for Apache Flink.-
Field Summary
FieldsFields inherited from class org.apache.wayang.core.platform.Platform
jsonSerializer
-
Method Summary
Modifier and TypeMethodDescriptionvoid
configureDefaults
(Configuration configuration) Configure default settings for this instance, e.g., to be able to createLoadProfileToTimeConverter
s.createLoadProfileToTimeConverter
(Configuration configuration) createTimeToCostConverter
(Configuration configuration) Creates aTimeToCostConverter
for this instance.getFlinkContext
(Job job) Configures the single maintainedExecutionEnvironment
according to thejob
and returns it.static FlinkPlatform
Methods inherited from class org.apache.wayang.core.platform.Platform
createExecutor, getConfigurationName, getInitializeMillis, getName, isSinglePlatformExecutionPossible, load, toString, warmUp
-
Field Details
-
INITIALIZATION_MS_CONFIG_KEY
- See Also:
-
-
Method Details
-
getInstance
-
getFlinkContext
Configures the single maintainedExecutionEnvironment
according to thejob
and returns it.- Returns:
- a
FlinkContextReference
wrapping theExecutionEnvironment
-
configureDefaults
Description copied from class:Platform
Configure default settings for this instance, e.g., to be able to createLoadProfileToTimeConverter
s.- Specified by:
configureDefaults
in classPlatform
- Parameters:
configuration
- that should be configured
-
getExecutorFactory
- Specified by:
getExecutorFactory
in classPlatform
-
createLoadProfileToTimeConverter
- Specified by:
createLoadProfileToTimeConverter
in classPlatform
- Returns:
- a default
LoadProfileToTimeConverter
-
createTimeToCostConverter
Description copied from class:Platform
Creates aTimeToCostConverter
for this instance.- Specified by:
createTimeToCostConverter
in classPlatform
- Parameters:
configuration
- configures theTimeToCostConverter
- Returns:
- the
TimeToCostConverter
-