ClusterID
- cluster idpublic class ExecutionContext<ClusterID> extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ExecutionContext.Builder
Builder for
ExecutionContext . |
static class |
ExecutionContext.SessionState
Represents the state that should be reused in one session.
|
public Configuration getFlinkConfig()
public SessionContext getOriginalSessionContext()
SessionContext
when initialize the ExecutionContext. It's usually used when resetting the session
properties.public ClassLoader getClassLoader()
public Environment getEnvironment()
public ClusterSpecification getClusterSpec()
public ClusterID getClusterId()
public ClusterDescriptor<ClusterID> createClusterDescriptor()
public ExecutionContext.SessionState getSessionState()
public <R> R wrapClassLoader(java.util.function.Supplier<R> supplier)
public QueryConfig getQueryConfig()
public TableEnvironment getTableEnvironment()
public ExecutionConfig getExecutionConfig()
public static ExecutionContext.Builder builder(Environment defaultEnv, SessionContext sessionContext, List<URL> dependencies, Configuration configuration, ClusterClientServiceLoader serviceLoader, org.apache.commons.cli.Options commandLineOptions, List<CustomCommandLine> commandLines)
ExecutionContext
.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.