public class DefaultContext extends Object
Constructor and Description |
---|
DefaultContext(Configuration flinkConfig,
List<URL> dependencies) |
DefaultContext(Map<String,String> flinkConfig,
List<URL> dependencies) |
Modifier and Type | Method and Description |
---|---|
List<URL> |
getDependencies() |
Configuration |
getFlinkConfig() |
static DefaultContext |
load(Configuration dynamicConfig,
List<URL> dependencies,
boolean discoverExecutionConfig)
Build the
DefaultContext from config.yaml, dynamic configuration and users specified
jars. |
public DefaultContext(Configuration flinkConfig, List<URL> dependencies)
public Configuration getFlinkConfig()
public static DefaultContext load(Configuration dynamicConfig, List<URL> dependencies, boolean discoverExecutionConfig)
DefaultContext
from config.yaml, dynamic configuration and users specified
jars.dynamicConfig
- user specified configuration.dependencies
- user specified jarsdiscoverExecutionConfig
- flag whether to load the execution configurationCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.