void |
SqlGatewayService.cancelOperation(SessionHandle sessionHandle,
OperationHandle operationHandle) |
Cancel the operation when it is not in terminal status.
|
void |
SqlGatewayService.closeOperation(SessionHandle sessionHandle,
OperationHandle operationHandle) |
Close the operation and release all used resource by the operation.
|
void |
SqlGatewayService.closeSession(SessionHandle sessionHandle) |
Close the Session.
|
List<String> |
SqlGatewayService.completeStatement(SessionHandle sessionHandle,
String statement,
int position) |
Returns a list of completion hints for the given statement at the given position.
|
void |
SqlGatewayService.configureSession(SessionHandle sessionHandle,
String statement,
long executionTimeoutMs) |
Using the statement to initialize the Session.
|
OperationHandle |
SqlGatewayService.executeStatement(SessionHandle sessionHandle,
String statement,
long executionTimeoutMs,
org.apache.flink.configuration.Configuration executionConfig) |
Execute the submitted statement.
|
ResultSet |
SqlGatewayService.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
long token,
int maxRows) |
Fetch the results from the operation.
|
ResultSet |
SqlGatewayService.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
FetchOrientation orientation,
int maxRows) |
Fetch the results from the operation.
|
String |
SqlGatewayService.getCurrentCatalog(SessionHandle sessionHandle) |
Return current catalog name.
|
org.apache.flink.table.functions.FunctionDefinition |
SqlGatewayService.getFunctionDefinition(SessionHandle sessionHandle,
org.apache.flink.table.catalog.UnresolvedIdentifier functionIdentifier) |
Get the specific definition of the function.
|
OperationInfo |
SqlGatewayService.getOperationInfo(SessionHandle sessionHandle,
OperationHandle operationHandle) |
|
org.apache.flink.table.catalog.ResolvedSchema |
SqlGatewayService.getOperationResultSchema(SessionHandle sessionHandle,
OperationHandle operationHandle) |
Get the result schema for the specified Operation.
|
Map<String,String> |
SqlGatewayService.getSessionConfig(SessionHandle sessionHandle) |
Get the current configuration of the Session.
|
EndpointVersion |
SqlGatewayService.getSessionEndpointVersion(SessionHandle sessionHandle) |
Get endpoint version that is negotiated in the openSession.
|
org.apache.flink.table.catalog.ResolvedCatalogBaseTable<?> |
SqlGatewayService.getTable(SessionHandle sessionHandle,
org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier) |
Return table of the given fully qualified name.
|
Set<String> |
SqlGatewayService.listCatalogs(SessionHandle sessionHandle) |
Return all available catalogs in the current session.
|
Set<String> |
SqlGatewayService.listDatabases(SessionHandle sessionHandle,
String catalogName) |
Return all available schemas in the given catalog.
|
Set<FunctionInfo> |
SqlGatewayService.listSystemFunctions(SessionHandle sessionHandle) |
List all available system functions.
|
Set<TableInfo> |
SqlGatewayService.listTables(SessionHandle sessionHandle,
String catalogName,
String databaseName,
Set<org.apache.flink.table.catalog.CatalogBaseTable.TableKind> tableKinds) |
Return all available tables/views in the given catalog and database.
|
Set<FunctionInfo> |
SqlGatewayService.listUserDefinedFunctions(SessionHandle sessionHandle,
String catalogName,
String databaseName) |
List all user defined functions.
|
OperationHandle |
SqlGatewayService.submitOperation(SessionHandle sessionHandle,
Callable<ResultSet> executor) |
Submit an operation and execute.
|