Modifier and Type | Method and Description |
---|---|
static SessionHandle |
ThriftObjectConversions.toSessionHandle(org.apache.hive.service.rpc.thrift.TOperationHandle tOperationHandle) |
static SessionHandle |
ThriftObjectConversions.toSessionHandle(org.apache.hive.service.rpc.thrift.TSessionHandle tSessionHandle) |
Modifier and Type | Method and Description |
---|---|
static Callable<ResultSet> |
OperationExecutorFactory.createGetCatalogsExecutor(SqlGatewayService service,
SessionHandle sessionHandle) |
static Callable<ResultSet> |
OperationExecutorFactory.createGetColumnsExecutor(SqlGatewayService service,
SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
String columnsName) |
static Callable<ResultSet> |
OperationExecutorFactory.createGetFunctionsExecutor(SqlGatewayService service,
SessionHandle sessionHandle,
String catalogName,
String databasePattern,
String functionNamePattern) |
static Callable<ResultSet> |
OperationExecutorFactory.createGetPrimaryKeys(SqlGatewayService service,
SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName) |
static Callable<ResultSet> |
OperationExecutorFactory.createGetSchemasExecutor(SqlGatewayService service,
SessionHandle sessionHandle,
String catalogName,
String schemaName) |
static Callable<ResultSet> |
OperationExecutorFactory.createGetTablesExecutor(SqlGatewayService service,
SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
Set<CatalogBaseTable.TableKind> tableKinds) |
static org.apache.hive.service.rpc.thrift.TOperationHandle |
ThriftObjectConversions.toTOperationHandle(SessionHandle sessionHandle,
OperationHandle operationHandle,
org.apache.hive.service.rpc.thrift.TOperationType operationType)
|
static org.apache.hive.service.rpc.thrift.TSessionHandle |
ThriftObjectConversions.toTSessionHandle(SessionHandle sessionHandle) |
Modifier and Type | Method and Description |
---|---|
SessionHandle |
SqlGatewayService.openSession(SessionEnvironment environment)
Open the
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.
|
OperationHandle |
SqlGatewayService.submitOperation(SessionHandle sessionHandle,
Callable<ResultSet> executor)
Submit an operation and execute.
|
Modifier and Type | Method and Description |
---|---|
static SessionHandle |
SessionHandle.create() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractOperationHandler.execute(SessionHandle sessionHandle,
OperationHandle operationHandle) |
void |
CancelOperationHandler.execute(SessionHandle sessionHandle,
OperationHandle operationHandle) |
void |
CloseOperationHandler.execute(SessionHandle sessionHandle,
OperationHandle operationHandle) |
protected String |
AbstractOperationHandler.getStatus(SessionHandle sessionHandle,
OperationHandle operationHandle) |
protected String |
CloseOperationHandler.getStatus(SessionHandle sessionHandle,
OperationHandle operationHandle) |
Constructor and Description |
---|
OperationMessageParameters(SessionHandle sessionHandle,
OperationHandle operationHandle) |
Modifier and Type | Method and Description |
---|---|
protected SessionHandle |
SessionHandleIdPathParameter.convertFromString(String sessionHandleId) |
Modifier and Type | Method and Description |
---|---|
protected String |
SessionHandleIdPathParameter.convertToString(SessionHandle sessionHandle) |
Constructor and Description |
---|
SessionMessageParameters(SessionHandle sessionHandle) |
Constructor and Description |
---|
FetchResultsTokenParameters(SessionHandle sessionHandle,
OperationHandle operationHandle,
Long token) |
Modifier and Type | Method and Description |
---|---|
SessionHandle |
SqlGatewayServiceImpl.openSession(SessionEnvironment environment) |
Modifier and Type | Method and Description |
---|---|
void |
SqlGatewayServiceImpl.cancelOperation(SessionHandle sessionHandle,
OperationHandle operationHandle) |
void |
SqlGatewayServiceImpl.closeOperation(SessionHandle sessionHandle,
OperationHandle operationHandle) |
void |
SqlGatewayServiceImpl.closeSession(SessionHandle sessionHandle) |
OperationHandle |
SqlGatewayServiceImpl.executeStatement(SessionHandle sessionHandle,
String statement,
long executionTimeoutMs,
Configuration executionConfig) |
ResultSet |
SqlGatewayServiceImpl.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
FetchOrientation orientation,
int maxRows) |
ResultSet |
SqlGatewayServiceImpl.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
long token,
int maxRows) |
String |
SqlGatewayServiceImpl.getCurrentCatalog(SessionHandle sessionHandle) |
FunctionDefinition |
SqlGatewayServiceImpl.getFunctionDefinition(SessionHandle sessionHandle,
UnresolvedIdentifier functionIdentifier) |
OperationInfo |
SqlGatewayServiceImpl.getOperationInfo(SessionHandle sessionHandle,
OperationHandle operationHandle) |
ResolvedSchema |
SqlGatewayServiceImpl.getOperationResultSchema(SessionHandle sessionHandle,
OperationHandle operationHandle) |
Session |
SqlGatewayServiceImpl.getSession(SessionHandle sessionHandle) |
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<String> |
SqlGatewayServiceImpl.listDatabases(SessionHandle sessionHandle,
String catalogName) |
Set<FunctionInfo> |
SqlGatewayServiceImpl.listSystemFunctions(SessionHandle sessionHandle) |
Set<TableInfo> |
SqlGatewayServiceImpl.listTables(SessionHandle sessionHandle,
String catalogName,
String databaseName,
Set<CatalogBaseTable.TableKind> tableKinds) |
Set<FunctionInfo> |
SqlGatewayServiceImpl.listUserDefinedFunctions(SessionHandle sessionHandle,
String catalogName,
String databaseName) |
OperationHandle |
SqlGatewayServiceImpl.submitOperation(SessionHandle sessionHandle,
Callable<ResultSet> executor) |
Modifier and Type | Method and Description |
---|---|
SessionHandle |
SessionContext.getSessionId() |
Modifier and Type | Method and Description |
---|---|
static SessionContext |
SessionContext.create(DefaultContext defaultContext,
SessionHandle sessionId,
SessionEnvironment environment,
ExecutorService operationExecutorService) |
Modifier and Type | Method and Description |
---|---|
SessionHandle |
Session.getSessionHandle() |
Modifier and Type | Method and Description |
---|---|
void |
SessionManager.closeSession(SessionHandle sessionId) |
int |
SessionManager.getOperationCount(SessionHandle sessionHandle) |
Session |
SessionManager.getSession(SessionHandle sessionHandle) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.