T
- cluster idpublic class ExecutionContext<T> extends Object
Modifier and Type | Class and Description |
---|---|
class |
ExecutionContext.EnvironmentInstance
ExecutionEnvironment and StreamExecutionEnvironment cannot be reused
across multiple queries because they are stateful. |
Constructor and Description |
---|
ExecutionContext(Environment defaultEnvironment,
SessionContext sessionContext,
List<URL> dependencies,
Configuration flinkConfig,
org.apache.commons.cli.Options commandLineOptions,
List<CustomCommandLine<?>> availableCommandLines) |
Modifier and Type | Method and Description |
---|---|
ClusterDescriptor<T> |
createClusterDescriptor() |
ExecutionContext.EnvironmentInstance |
createEnvironmentInstance() |
ClassLoader |
getClassLoader() |
T |
getClusterId() |
ClusterSpecification |
getClusterSpec() |
Environment |
getMergedEnvironment() |
SessionContext |
getSessionContext() |
public ExecutionContext(Environment defaultEnvironment, SessionContext sessionContext, List<URL> dependencies, Configuration flinkConfig, org.apache.commons.cli.Options commandLineOptions, List<CustomCommandLine<?>> availableCommandLines)
public SessionContext getSessionContext()
public ClassLoader getClassLoader()
public Environment getMergedEnvironment()
public ClusterSpecification getClusterSpec()
public T getClusterId()
public ClusterDescriptor<T> createClusterDescriptor() throws Exception
Exception
public ExecutionContext.EnvironmentInstance createEnvironmentInstance()
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.