Package | Description |
---|---|
org.apache.flink.table.client.cli | |
org.apache.flink.table.client.gateway | |
org.apache.flink.table.client.gateway.local |
Modifier and Type | Method and Description |
---|---|
SessionContext |
CliClient.getContext() |
Constructor and Description |
---|
CliClient(SessionContext context,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
SessionContext |
SessionContext.copy() |
Modifier and Type | Method and Description |
---|---|
void |
Executor.cancelQuery(SessionContext session,
String resultId)
Cancels a table program and stops the result retrieval.
|
ResultDescriptor |
Executor.executeQuery(SessionContext session,
String query)
Submits a Flink job (detached) and returns the result descriptor.
|
String |
Executor.explainStatement(SessionContext session,
String statement)
Returns a string-based explanation about AST and execution plan of the given statement.
|
Map<String,String> |
Executor.getSessionProperties(SessionContext session)
Lists all session properties that are defined by the executor and the session.
|
org.apache.flink.table.api.TableSchema |
Executor.getTableSchema(SessionContext session,
String name)
Returns the schema of a table.
|
List<String> |
Executor.listTables(SessionContext session)
Lists all tables known to the executor.
|
TypedResult<List<Tuple2<Boolean,Row>>> |
Executor.retrieveResultChanges(SessionContext session,
String resultId)
Asks for the next changelog results (non-blocking).
|
TypedResult<Integer> |
Executor.snapshotResult(SessionContext session,
String resultId,
int pageSize)
Creates an immutable result snapshot of the running Flink job.
|
void |
Executor.stop(SessionContext session)
Stops the executor.
|
Modifier and Type | Method and Description |
---|---|
SessionContext |
ExecutionContext.getSessionContext() |
Modifier and Type | Method and Description |
---|---|
void |
LocalExecutor.cancelQuery(SessionContext session,
String resultId) |
ResultDescriptor |
LocalExecutor.executeQuery(SessionContext session,
String query) |
String |
LocalExecutor.explainStatement(SessionContext session,
String statement) |
Map<String,String> |
LocalExecutor.getSessionProperties(SessionContext session) |
org.apache.flink.table.api.TableSchema |
LocalExecutor.getTableSchema(SessionContext session,
String name) |
List<String> |
LocalExecutor.listTables(SessionContext session) |
TypedResult<List<Tuple2<Boolean,Row>>> |
LocalExecutor.retrieveResultChanges(SessionContext session,
String resultId) |
TypedResult<Integer> |
LocalExecutor.snapshotResult(SessionContext session,
String resultId,
int pageSize) |
void |
LocalExecutor.stop(SessionContext session) |
Constructor and Description |
---|
ExecutionContext(Environment defaultEnvironment,
SessionContext sessionContext,
List<URL> dependencies,
Configuration flinkConfig,
org.apache.commons.cli.Options commandLineOptions,
List<CustomCommandLine<?>> availableCommandLines) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.