@Test public void testFunctions() throws Exception { final ExecutionContext<?> context = createDefaultExecutionContext(); final TableEnvironment tableEnv = context.createEnvironmentInstance().getTableEnvironment(); final String[] expected = new String[]{"scalarUDF", "tableUDF", "aggregateUDF"}; final String[] actual = tableEnv.listUserDefinedFunctions(); Arrays.sort(expected); Arrays.sort(actual); assertArrayEquals(expected, actual); }
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);  }