@Test public void testConfiguration() throws Exception { final ExecutionContext<?> context = createConfigurationExecutionContext(); final TableEnvironment tableEnv = context.createEnvironmentInstance().getTableEnvironment(); assertEquals( 100, tableEnv.getConfig().getConfiguration().getInteger( ExecutionConfigOptions.TABLE_EXEC_SORT_DEFAULT_LIMIT)); assertTrue( tableEnv.getConfig().getConfiguration().getBoolean( ExecutionConfigOptions.TABLE_EXEC_SPILL_COMPRESSION_ENABLED)); assertEquals( "128kb", tableEnv.getConfig().getConfiguration().getString( ExecutionConfigOptions.TABLE_EXEC_SPILL_COMPRESSION_BLOCK_SIZE)); assertTrue( tableEnv.getConfig().getConfiguration().getBoolean( OptimizerConfigOptions.TABLE_OPTIMIZER_JOIN_REORDER_ENABLED)); assertEquals( ExecutionConfigOptions.TABLE_EXEC_SORT_ASYNC_MERGE_ENABLED.defaultValue(), tableEnv.getConfig().getConfiguration().getBoolean( ExecutionConfigOptions.TABLE_EXEC_SORT_ASYNC_MERGE_ENABLED)); assertEquals( ExecutionConfigOptions.TABLE_EXEC_SHUFFLE_MODE.defaultValue(), tableEnv.getConfig().getConfiguration().getString( ExecutionConfigOptions.TABLE_EXEC_SHUFFLE_MODE)); assertEquals( OptimizerConfigOptions.TABLE_OPTIMIZER_BROADCAST_JOIN_THRESHOLD.defaultValue().longValue(), tableEnv.getConfig().getConfiguration().getLong( OptimizerConfigOptions.TABLE_OPTIMIZER_BROADCAST_JOIN_THRESHOLD)); }
public EnvironmentInstance createEnvironmentInstance() { try { return wrapClassLoader(EnvironmentInstance::new); } catch (Throwable t) { throw new SqlExecutionException("Could not create environment instance.", t); } }
ExecutionContext { public EnvironmentInstance createEnvironmentInstance() { try { return wrapClassLoader(EnvironmentInstance::new); } catch (Throwable t) { throw new SqlExecutionException("Could not create environment instance.", t); } } }
ExecutionContext { public EnvironmentInstance createEnvironmentInstance() { try { return wrapClassLoader(EnvironmentInstance::new); } catch (Throwable t) { throw new SqlExecutionException("Could not create environment instance.", t); } } ExecutionContext(Environment defaultEnvironment, SessionContext sessionContext, List<URL> dependencies,
			Configuration flinkConfig, Options commandLineOptions, List<CustomCommandLine<?>> availableCommandLines); }
ExecutionContext { public EnvironmentInstance createEnvironmentInstance() { try { return wrapClassLoader(EnvironmentInstance::new); } catch (Throwable t) { throw new SqlExecutionException("Could not create environment instance.", t); } } ExecutionContext(Environment defaultEnvironment, SessionContext sessionContext, List<URL> dependencies,
			Configuration flinkConfig, Options commandLineOptions, List<CustomCommandLine<?>> availableCommandLines); SessionContext getSessionContext(); ClassLoader getClassLoader(); Environment getMergedEnvironment(); ClusterSpecification getClusterSpec(); T getClusterId(); ClusterDescriptor<T> createClusterDescriptor(); EnvironmentInstance createEnvironmentInstance(); Map<String, Catalog> getCatalogs(); Map<String, TableSource<?>> getTableSources(); Map<String, TableSink<?>> getTableSinks(); R wrapClassLoader(Supplier<R> supplier); }
ExecutionContext { public EnvironmentInstance createEnvironmentInstance() { try { return wrapClassLoader(EnvironmentInstance::new); } catch (Throwable t) { throw new SqlExecutionException("Could not create environment instance.", t); } } ExecutionContext(Environment defaultEnvironment, SessionContext sessionContext, List<URL> dependencies,
			Configuration flinkConfig, Options commandLineOptions, List<CustomCommandLine<?>> availableCommandLines); SessionContext getSessionContext(); ClassLoader getClassLoader(); Environment getMergedEnvironment(); ClusterSpecification getClusterSpec(); T getClusterId(); ClusterDescriptor<T> createClusterDescriptor(); EnvironmentInstance createEnvironmentInstance(); Map<String, Catalog> getCatalogs(); Map<String, TableSource<?>> getTableSources(); Map<String, TableSink<?>> getTableSinks(); R wrapClassLoader(Supplier<R> supplier);  }