Uses of Class
org.apache.flink.table.client.gateway.SqlExecutionException

Packages that use SqlExecutionException

Package	Description
org.apache.flink.table.client.cli
org.apache.flink.table.client.gateway
org.apache.flink.table.client.gateway.local
org.apache.flink.table.client.gateway.local.result

Uses of SqlExecutionException in org.apache.flink.table.client.cli

Methods in org.apache.flink.table.client.cli with parameters of type SqlExecutionException

Modifier and Type	Method and Description
protected void	CliView.close(SqlExecutionException e)

Methods in org.apache.flink.table.client.cli that throw SqlExecutionException

Modifier and Type	Method and Description
void	CliTableauResultView.displayResults()

Uses of SqlExecutionException in org.apache.flink.table.client.gateway

Methods in org.apache.flink.table.client.gateway that throw SqlExecutionException

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.
TableResult	Executor.executeModifyOperations(String sessionId, List<ModifyOperation> operations) Executes modify operations, and return TableResult as execution result.
TableResult	Executor.executeOperation(String sessionId, Operation operation) Executes an operation, and return TableResult as execution result.
ResultDescriptor	Executor.executeQuery(String sessionId, QueryOperation query) Submits a Flink SQL query job (detached) and returns the result descriptor.
ReadableConfig	Executor.getSessionConfig(String sessionId) Returns a ReadableConfig of all session configurations that are defined by the executor and the session.
Map<String,String>	Executor.getSessionConfigMap(String sessionId) Returns a copy of Map of all session configurations that are defined by the executor and the session.
String	Executor.openSession(String sessionId) Open a new session by using the given session id.
Operation	Executor.parseStatement(String sessionId, String statement) Parse a SQL statement to Operation.
void	Executor.resetSessionProperties(String sessionId) Reset all the properties for the given session identifier.
void	Executor.resetSessionProperty(String sessionId, String key) Reset given key's the session property for default value, if key is not defined in config file, then remove it.
TypedResult<List<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.

Uses of SqlExecutionException in org.apache.flink.table.client.gateway.local

Methods in org.apache.flink.table.client.gateway.local that throw SqlExecutionException

Modifier and Type	Method and Description
void	LocalExecutor.cancelQuery(String sessionId, String resultId)
void	LocalExecutor.closeSession(String sessionId)
TableResult	LocalExecutor.executeModifyOperations(String sessionId, List<ModifyOperation> operations)
TableResult	LocalExecutor.executeOperation(String sessionId, Operation operation)
ResultDescriptor	LocalExecutor.executeQuery(String sessionId, QueryOperation query)
protected ExecutionContext	LocalExecutor.getExecutionContext(String sessionId) Get the existed ExecutionContext from contextMap, or thrown exception if does not exist.
ReadableConfig	LocalExecutor.getSessionConfig(String sessionId)
Map<String,String>	LocalExecutor.getSessionConfigMap(String sessionId)
String	LocalExecutor.openSession(String sessionId)
Operation	LocalExecutor.parseStatement(String sessionId, String statement)
void	LocalExecutor.resetSessionProperties(String sessionId)
void	LocalExecutor.resetSessionProperty(String sessionId, String key)
TypedResult<List<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)

Uses of SqlExecutionException in org.apache.flink.table.client.gateway.local.result

Fields in org.apache.flink.table.client.gateway.local.result with type parameters of type SqlExecutionException

Modifier and Type	Field and Description
protected AtomicReference<SqlExecutionException>	CollectResultBase.executionException