Class DefaultContext


  • public class DefaultContext
    extends Object
    The context memorized initial configuration.
    • Constructor Detail

      • 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,
                                          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