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 SQL query job (detached) and returns the result descriptor.
|
ProgramTargetDescriptor |
Executor.executeUpdate(SessionContext session,
String statement)
Submits a Flink SQL update statement such as INSERT INTO.
|
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.
|
TableSchema |
Executor.getTableSchema(SessionContext session,
String name)
Returns the schema of a table.
|
List<String> |
Executor.listCatalogs(SessionContext session)
Lists all registered catalogs.
|
List<String> |
Executor.listDatabases(SessionContext session)
Lists all databases in the current catalog.
|
List<String> |
Executor.listTables(SessionContext session)
Lists all tables in the current database of the current catalog.
|
List<String> |
Executor.listUserDefinedFunctions(SessionContext session)
Lists all user-defined functions 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.
|
void |
Executor.useCatalog(SessionContext session,
String catalogName)
Sets a catalog with given name as the current catalog.
|
void |
Executor.useDatabase(SessionContext session,
String databaseName)
Sets a database with given name as the current database of the current catalog.
|
void |
Executor.validateSession(SessionContext session)
Validates the current session.
|
Modifier and Type | Field and Description |
---|---|
protected SqlExecutionException |
CollectStreamResult.executionException |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.