Modifier and Type | Method and Description |
---|---|
protected void |
CliView.close(SqlExecutionException e) |
Modifier and Type | Method and Description |
---|---|
void |
CliTableauResultView.displayBatchResults() |
void |
CliTableauResultView.displayStreamResults() |
Modifier and Type | Method and Description |
---|---|
void |
Executor.cancelQuery(String sessionId,
String resultId)
Cancels a table program and stops the result retrieval.
|
void |
Executor.closeSession(String sessionId)
Close the resources of session for given session id.
|
void |
Executor.createTable(String sessionId,
String ddl)
Create a table with a DDL statement.
|
void |
Executor.dropTable(String sessionId,
String ddl)
Drop a table with a DDL statement.
|
ResultDescriptor |
Executor.executeQuery(String sessionId,
String query)
Submits a Flink SQL query job (detached) and returns the result descriptor.
|
TableResult |
Executor.executeSql(String sessionId,
String statement)
Executes a SQL statement.
|
ProgramTargetDescriptor |
Executor.executeUpdate(String sessionId,
String statement)
Submits a Flink SQL update statement such as INSERT INTO.
|
Map<String,String> |
Executor.getSessionProperties(String sessionId)
Lists all session properties that are defined by the executor and the session.
|
TableSchema |
Executor.getTableSchema(String sessionId,
String name)
Returns the schema of a table.
|
List<String> |
Executor.listCatalogs(String sessionid)
Lists all registered catalogs.
|
List<String> |
Executor.listDatabases(String sessionId)
Lists all databases in the current catalog.
|
List<String> |
Executor.listFunctions(String sessionId)
Lists all functions known to the executor.
|
List<String> |
Executor.listModules(String sessionId)
Lists all modules known to the executor in their loaded order.
|
List<String> |
Executor.listTables(String sessionId)
Lists all tables in the current database of the current catalog.
|
List<String> |
Executor.listUserDefinedFunctions(String sessionId)
Lists all user-defined functions known to the executor.
|
String |
Executor.openSession(SessionContext session)
Open a new session by using the given
SessionContext . |
void |
Executor.resetSessionProperties(String sessionId)
Reset all the properties for the given session identifier.
|
TypedResult<List<Tuple2<Boolean,Row>>> |
Executor.retrieveResultChanges(String sessionId,
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.
|
void |
Executor.setSessionProperty(String sessionId,
String key,
String value)
Set given key's session property to the specific value.
|
TypedResult<Integer> |
Executor.snapshotResult(String sessionId,
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(String sessionId,
String catalogName)
Sets a catalog with given name as the current catalog.
|
void |
Executor.useDatabase(String sessionId,
String databaseName)
Sets a database with given name as the current database of the current catalog.
|
Modifier and Type | Method and Description |
---|---|
void |
LocalExecutor.cancelQuery(String sessionId,
String resultId) |
void |
LocalExecutor.closeSession(String sessionId) |
void |
LocalExecutor.createTable(String sessionId,
String ddl) |
void |
LocalExecutor.dropTable(String sessionId,
String ddl) |
ResultDescriptor |
LocalExecutor.executeQuery(String sessionId,
String query) |
TableResult |
LocalExecutor.executeSql(String sessionId,
String statement) |
ProgramTargetDescriptor |
LocalExecutor.executeUpdate(String sessionId,
String statement) |
protected ExecutionContext<?> |
LocalExecutor.getExecutionContext(String sessionId)
Get the existed
ExecutionContext from contextMap, or thrown exception if does not
exist. |
Map<String,String> |
LocalExecutor.getSessionProperties(String sessionId) |
TableSchema |
LocalExecutor.getTableSchema(String sessionId,
String name) |
List<String> |
LocalExecutor.listCatalogs(String sessionId) |
List<String> |
LocalExecutor.listDatabases(String sessionId) |
List<String> |
LocalExecutor.listFunctions(String sessionId) |
List<String> |
LocalExecutor.listModules(String sessionId) |
List<String> |
LocalExecutor.listTables(String sessionId) |
List<String> |
LocalExecutor.listUserDefinedFunctions(String sessionId) |
String |
LocalExecutor.openSession(SessionContext sessionContext) |
void |
LocalExecutor.resetSessionProperties(String sessionId) |
TypedResult<List<Tuple2<Boolean,Row>>> |
LocalExecutor.retrieveResultChanges(String sessionId,
String resultId) |
List<Row> |
LocalExecutor.retrieveResultPage(String resultId,
int page) |
void |
LocalExecutor.setSessionProperty(String sessionId,
String key,
String value) |
TypedResult<Integer> |
LocalExecutor.snapshotResult(String sessionId,
String resultId,
int pageSize) |
void |
LocalExecutor.useCatalog(String sessionId,
String catalogName) |
void |
LocalExecutor.useDatabase(String sessionId,
String databaseName) |
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<SqlExecutionException> |
CollectStreamResult.executionException |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.