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 |
---|---|
protected void |
CliView.close(SqlExecutionException e) |
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).
|
List<Row> |
Executor.retrieveResultPage(String resultId,
int page)
Returns the rows that are part of the current page or throws an exception if the snapshot has been expired.
|
TypedResult<Integer> |
Executor.snapshotResult(SessionContext session,
String resultId,
int pageSize)
Creates an immutable result snapshot of the running Flink job.
|
void |
Executor.start()
Starts the executor and ensures that its is ready for commands to be executed.
|
Modifier and Type | Field and Description |
---|---|
protected SqlExecutionException |
CollectStreamResult.executionException |
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) |
List<Row> |
LocalExecutor.retrieveResultPage(String resultId,
int page) |
TypedResult<Integer> |
LocalExecutor.snapshotResult(SessionContext session,
String resultId,
int pageSize) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.