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 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
.public void close()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.