Modifier and Type | Method and Description |
---|---|
static OperationHandle |
ThriftObjectConversions.toOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle tOperationHandle) |
Modifier and Type | Method and Description |
---|---|
static org.apache.hive.service.rpc.thrift.TOperationHandle |
ThriftObjectConversions.toTOperationHandle(SessionHandle sessionHandle,
OperationHandle operationHandle,
org.apache.hive.service.rpc.thrift.TOperationType operationType)
|
Modifier and Type | Method and Description |
---|---|
OperationHandle |
SqlGatewayService.executeStatement(SessionHandle sessionHandle,
String statement,
long executionTimeoutMs,
Configuration executionConfig)
Execute the submitted statement.
|
OperationHandle |
SqlGatewayService.submitOperation(SessionHandle sessionHandle,
Callable<ResultSet> executor)
Submit an operation and execute.
|
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.
|
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.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static OperationHandle |
OperationHandle.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) |
Modifier and Type | Method and Description |
---|---|
protected OperationHandle |
OperationHandleIdPathParameter.convertFromString(String operationHandleId) |
Modifier and Type | Method and Description |
---|---|
protected String |
OperationHandleIdPathParameter.convertToString(OperationHandle operationHandle) |
Constructor and Description |
---|
OperationMessageParameters(SessionHandle sessionHandle,
OperationHandle operationHandle) |
Constructor and Description |
---|
FetchResultsTokenParameters(SessionHandle sessionHandle,
OperationHandle operationHandle,
Long token) |
Modifier and Type | Method and Description |
---|---|
OperationHandle |
SqlGatewayServiceImpl.executeStatement(SessionHandle sessionHandle,
String statement,
long executionTimeoutMs,
Configuration executionConfig) |
OperationHandle |
SqlGatewayServiceImpl.submitOperation(SessionHandle sessionHandle,
Callable<ResultSet> executor) |
Modifier and Type | Method and Description |
---|---|
void |
SqlGatewayServiceImpl.cancelOperation(SessionHandle sessionHandle,
OperationHandle operationHandle) |
void |
SqlGatewayServiceImpl.closeOperation(SessionHandle sessionHandle,
OperationHandle operationHandle) |
ResultSet |
SqlGatewayServiceImpl.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
FetchOrientation orientation,
int maxRows) |
ResultSet |
SqlGatewayServiceImpl.fetchResults(SessionHandle sessionHandle,
OperationHandle operationHandle,
long token,
int maxRows) |
OperationInfo |
SqlGatewayServiceImpl.getOperationInfo(SessionHandle sessionHandle,
OperationHandle operationHandle) |
ResolvedSchema |
SqlGatewayServiceImpl.getOperationResultSchema(SessionHandle sessionHandle,
OperationHandle operationHandle) |
Modifier and Type | Method and Description |
---|---|
OperationHandle |
OperationManager.submitOperation(Callable<ResultSet> executor)
Submit the operation to the
OperationManager . |
OperationHandle |
OperationManager.submitOperation(java.util.function.Function<OperationHandle,ResultFetcher> fetcherSupplier)
Submit the operation to the
OperationManager . |
Modifier and Type | Method and Description |
---|---|
void |
OperationManager.cancelOperation(OperationHandle operationHandle)
Cancel the execution of the operation.
|
void |
OperationManager.closeOperation(OperationHandle operationHandle)
Close the operation and release all resources used by the
OperationManager.Operation . |
ResultFetcher |
OperationExecutor.executeStatement(OperationHandle handle,
String statement) |
ResultSet |
OperationManager.fetchResults(OperationHandle operationHandle,
FetchOrientation orientation,
int maxRows) |
ResultSet |
OperationManager.fetchResults(OperationHandle operationHandle,
long token,
int maxRows)
Get the results of the operation.
|
OperationManager.Operation |
OperationManager.getOperation(OperationHandle operationHandle) |
OperationInfo |
OperationManager.getOperationInfo(OperationHandle operationHandle)
Get the
OperationInfo of the operation. |
ResolvedSchema |
OperationManager.getOperationResultSchema(OperationHandle operationHandle)
Get the
ResolvedSchema of the operation. |
Modifier and Type | Method and Description |
---|---|
OperationHandle |
OperationManager.submitOperation(java.util.function.Function<OperationHandle,ResultFetcher> fetcherSupplier)
Submit the operation to the
OperationManager . |
Constructor and Description |
---|
Operation(OperationHandle operationHandle,
Callable<ResultFetcher> resultSupplier) |
Constructor and Description |
---|
ResultFetcher(OperationHandle operationHandle,
ResolvedSchema resultSchema,
CloseableIterator<RowData> resultRows) |
ResultFetcher(OperationHandle operationHandle,
ResolvedSchema resultSchema,
List<RowData> rows) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.