Package | Description |
---|---|
org.apache.flink.table.gateway.api | |
org.apache.flink.table.gateway.service | |
org.apache.flink.table.gateway.service.session |
Modifier and Type | Method and Description |
---|---|
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 . |
OperationHandle |
SqlGatewayService.executeStatement(SessionHandle sessionHandle,
String statement,
long executionTimeoutMs,
Configuration executionConfig)
Execute the submitted statement.
|
ResultSet |
SqlGatewayService.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
FetchOrientation orientation,
int maxRows)
Fetch the results from the operation.
|
ResultSet |
SqlGatewayService.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
long token,
int maxRows)
Fetch the results from the operation.
|
String |
SqlGatewayService.getCurrentCatalog(SessionHandle sessionHandle)
Return current catalog name.
|
FunctionDefinition |
SqlGatewayService.getFunctionDefinition(SessionHandle sessionHandle,
UnresolvedIdentifier functionIdentifier)
Get the specific definition of the function.
|
OperationInfo |
SqlGatewayService.getOperationInfo(SessionHandle sessionHandle,
OperationHandle operationHandle)
Get the
OperationInfo of the operation. |
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.
|
ResolvedCatalogBaseTable<?> |
SqlGatewayService.getTable(SessionHandle sessionHandle,
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<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.
|
SessionHandle |
SqlGatewayService.openSession(SessionEnvironment environment)
Open the
Session . |
OperationHandle |
SqlGatewayService.submitOperation(SessionHandle sessionHandle,
Callable<ResultSet> executor)
Submit an operation and execute.
|
Modifier and Type | Method and Description |
---|---|
void |
SqlGatewayServiceImpl.closeSession(SessionHandle sessionHandle) |
OperationHandle |
SqlGatewayServiceImpl.executeStatement(SessionHandle sessionHandle,
String statement,
long executionTimeoutMs,
Configuration executionConfig) |
ResultSet |
SqlGatewayServiceImpl.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
long token,
int maxRows) |
FunctionDefinition |
SqlGatewayServiceImpl.getFunctionDefinition(SessionHandle sessionHandle,
UnresolvedIdentifier functionIdentifier) |
ResolvedSchema |
SqlGatewayServiceImpl.getOperationResultSchema(SessionHandle sessionHandle,
OperationHandle operationHandle) |
Map<String,String> |
SqlGatewayServiceImpl.getSessionConfig(SessionHandle sessionHandle) |
EndpointVersion |
SqlGatewayServiceImpl.getSessionEndpointVersion(SessionHandle sessionHandle) |
ResolvedCatalogBaseTable<?> |
SqlGatewayServiceImpl.getTable(SessionHandle sessionHandle,
ObjectIdentifier tableIdentifier) |
Set<String> |
SqlGatewayServiceImpl.listCatalogs(SessionHandle sessionHandle) |
Set<FunctionInfo> |
SqlGatewayServiceImpl.listUserDefinedFunctions(SessionHandle sessionHandle,
String catalogName,
String databaseName) |
SessionHandle |
SqlGatewayServiceImpl.openSession(SessionEnvironment environment) |
OperationHandle |
SqlGatewayServiceImpl.submitOperation(SessionHandle sessionHandle,
Callable<ResultSet> executor) |
Modifier and Type | Method and Description |
---|---|
void |
SessionManager.closeSession(SessionHandle sessionId) |
Session |
SessionManager.getSession(SessionHandle sessionHandle) |
Session |
SessionManager.openSession(SessionEnvironment environment)
Register the session into the
SessionManager . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.