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(Configuration flinkConfig, List<URL> dependencies)

Method Summary

Modifier and Type	Method and Description
List<URL>	getDependencies()
Configuration	getFlinkConfig()
static DefaultContext	load(Configuration dynamicConfig, List<URL> dependencies, boolean discoverExecutionConfig, boolean discoverPythonJar) Build the DefaultContext from flink-conf.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(Configuration flinkConfig,
                      List<URL> dependencies)

Method Detail

getFlinkConfig

public Configuration getFlinkConfig()

getDependencies

public List<URL> getDependencies()

load

public static DefaultContext load(Configuration dynamicConfig,
                                  List<URL> dependencies,
                                  boolean discoverExecutionConfig,
                                  boolean discoverPythonJar)

Build the DefaultContext from flink-conf.yaml, dynamic configuration and users specified jars.

Parameters:

dynamicConfig - user specified configuration.

dependencies - user specified jars

discoverExecutionConfig - flag whether to load the execution configuration

discoverPythonJar - flag whetehr to load the python jar