Package | Description |
---|---|
org.apache.flink.table.client.gateway | |
org.apache.flink.table.client.gateway.local |
Modifier and Type | Method and Description |
---|---|
String |
Executor.openSession(SessionContext session)
Open a new session by using the given
SessionContext . |
Modifier and Type | Method and Description |
---|---|
SessionContext |
ExecutionContext.getOriginalSessionContext()
Get the
SessionContext when initialize the ExecutionContext. |
Modifier and Type | Method and Description |
---|---|
static ExecutionContext.Builder |
ExecutionContext.builder(Environment defaultEnv,
SessionContext sessionContext,
List<URL> dependencies,
Configuration configuration,
ClusterClientServiceLoader serviceLoader,
org.apache.commons.cli.Options commandLineOptions,
List<CustomCommandLine> commandLines)
Returns a builder for this
ExecutionContext . |
String |
LocalExecutor.openSession(SessionContext sessionContext) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.