org.apache.flink.table.gateway.service.context

Class DefaultContext

java.lang.Object

org.apache.flink.table.gateway.service.context.DefaultContext

public class DefaultContext
extends Object

The context memorized initial configuration.

Constructor Summary

Constructors

Constructor and Description
DefaultContext(org.apache.flink.configuration.Configuration flinkConfig, List<URL> dependencies)
DefaultContext(Map<String,String> flinkConfig, List<URL> dependencies)

Method Summary

Modifier and Type	Method and Description
List<URL>	getDependencies()
org.apache.flink.configuration.Configuration	getFlinkConfig()
static DefaultContext	load(org.apache.flink.configuration.Configuration dynamicConfig, List<URL> dependencies, boolean discoverExecutionConfig) Build the DefaultContext from config.yaml, dynamic configuration and users specified jars.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultContext

public DefaultContext(Map<String,String> flinkConfig,
                      List<URL> dependencies)

DefaultContext

public DefaultContext(org.apache.flink.configuration.Configuration flinkConfig,
                      List<URL> dependencies)

Method Detail

getFlinkConfig

public org.apache.flink.configuration.Configuration getFlinkConfig()

getDependencies

public List<URL> getDependencies()

load

public static DefaultContext load(org.apache.flink.configuration.Configuration dynamicConfig,
                                  List<URL> dependencies,
                                  boolean discoverExecutionConfig)

Build the DefaultContext from config.yaml, dynamic configuration and users specified jars.

Parameters:

dynamicConfig - user specified configuration.

dependencies - user specified jars

discoverExecutionConfig - flag whether to load the execution configuration