org.apache.hive.service.cli.operation

Class OperationManager

java.lang.Object

org.apache.hive.service.AbstractService

org.apache.hive.service.cli.operation.OperationManager

All Implemented Interfaces:

Service

public class OperationManager
extends AbstractService

OperationManager.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hive.service.Service

Service.STATE

Constructor Summary

Constructors

Constructor and Description
OperationManager()

Method Summary

Modifier and Type	Method and Description
void	cancelOperation(OperationHandle opHandle) Cancel the running operation unless it is already in a terminal state
void	cancelOperation(OperationHandle opHandle, String errMsg) Cancel the running operation unless it is already in a terminal state
void	closeOperation(OperationHandle opHandle)
List<QueryInfo>	getHistoricalQueryInfos()
List<QueryInfo>	getLiveQueryInfos()
Operation	getOperation(OperationHandle operationHandle)
Operation	getOperationByQueryId(String queryId)
RowSet	getOperationLogRowSet(OperationHandle opHandle, FetchOrientation orientation, long maxRows, HiveConf hConf)
RowSet	getOperationNextRowSet(OperationHandle opHandle, FetchOrientation orientation, long maxRows)
TableSchema	getOperationResultSetSchema(OperationHandle opHandle)
Collection<Operation>	getOperations()
OperationStatus	getOperationStatus(OperationHandle opHandle)
QueryInfo	getQueryInfo(String handle)
void	init(HiveConf hiveConf) Initialize the service.
ExecuteStatementOperation	newExecuteStatementOperation(HiveSession parentSession, String statement, Map<String,String> confOverlay, boolean runAsync, long queryTimeout)
GetCatalogsOperation	newGetCatalogsOperation(HiveSession parentSession)
GetColumnsOperation	newGetColumnsOperation(HiveSession parentSession, String catalogName, String schemaName, String tableName, String columnName)
GetCrossReferenceOperation	newGetCrossReferenceOperation(HiveSession session, String primaryCatalog, String primarySchema, String primaryTable, String foreignCatalog, String foreignSchema, String foreignTable)
GetFunctionsOperation	newGetFunctionsOperation(HiveSession parentSession, String catalogName, String schemaName, String functionName)
GetPrimaryKeysOperation	newGetPrimaryKeysOperation(HiveSession parentSession, String catalogName, String schemaName, String tableName)
GetSchemasOperation	newGetSchemasOperation(HiveSession parentSession, String catalogName, String schemaName)
MetadataOperation	newGetTablesOperation(HiveSession parentSession, String catalogName, String schemaName, String tableName, List<String> tableTypes)
GetTableTypesOperation	newGetTableTypesOperation(HiveSession parentSession)
GetTypeInfoOperation	newGetTypeInfoOperation(HiveSession parentSession)
List<Operation>	removeExpiredOperations(OperationHandle[] handles)
void	start() Start the service.
void	stop() Stop the service.

Methods inherited from class org.apache.hive.service.AbstractService

getHiveConf, getName, getServiceState, getStartTime, register, setHiveConf, unregister

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OperationManager

public OperationManager()

Method Detail

init

public void init(HiveConf hiveConf)

Description copied from class: AbstractService

Initialize the service. The transition must be from Service.STATE.NOTINITED to Service.STATE.INITED unless the operation failed and an exception was raised.

Specified by:

init in interface Service

Overrides:

init in class AbstractService

start

public void start()

Description copied from class: AbstractService

Start the service. The transition should be from Service.STATE.INITED to Service.STATE.STARTED unless the operation failed and an exception was raised.

Specified by:

start in interface Service

Overrides:

start in class AbstractService

stop

public void stop()

Description copied from class: AbstractService

Stop the service. This operation must be designed to complete regardless of the initial state of the service, including the state of all its internal fields.

Specified by:

stop in interface Service

Overrides:

stop in class AbstractService

newExecuteStatementOperation

public ExecuteStatementOperation newExecuteStatementOperation(HiveSession parentSession,
                                                              String statement,
                                                              Map<String,String> confOverlay,
                                                              boolean runAsync,
                                                              long queryTimeout)
                                                       throws HiveSQLException

Throws:

HiveSQLException

newGetTypeInfoOperation

public GetTypeInfoOperation newGetTypeInfoOperation(HiveSession parentSession)

newGetCatalogsOperation

public GetCatalogsOperation newGetCatalogsOperation(HiveSession parentSession)

newGetSchemasOperation

public GetSchemasOperation newGetSchemasOperation(HiveSession parentSession,
                                                  String catalogName,
                                                  String schemaName)

newGetTablesOperation

public MetadataOperation newGetTablesOperation(HiveSession parentSession,
                                               String catalogName,
                                               String schemaName,
                                               String tableName,
                                               List<String> tableTypes)

newGetTableTypesOperation

public GetTableTypesOperation newGetTableTypesOperation(HiveSession parentSession)

newGetColumnsOperation

public GetColumnsOperation newGetColumnsOperation(HiveSession parentSession,
                                                  String catalogName,
                                                  String schemaName,
                                                  String tableName,
                                                  String columnName)

newGetFunctionsOperation

public GetFunctionsOperation newGetFunctionsOperation(HiveSession parentSession,
                                                      String catalogName,
                                                      String schemaName,
                                                      String functionName)

newGetPrimaryKeysOperation

public GetPrimaryKeysOperation newGetPrimaryKeysOperation(HiveSession parentSession,
                                                          String catalogName,
                                                          String schemaName,
                                                          String tableName)

newGetCrossReferenceOperation

public GetCrossReferenceOperation newGetCrossReferenceOperation(HiveSession session,
                                                                String primaryCatalog,
                                                                String primarySchema,
                                                                String primaryTable,
                                                                String foreignCatalog,
                                                                String foreignSchema,
                                                                String foreignTable)

getOperation

public Operation getOperation(OperationHandle operationHandle)
                       throws HiveSQLException

Throws:

HiveSQLException

getOperationStatus

public OperationStatus getOperationStatus(OperationHandle opHandle)
                                   throws HiveSQLException

Throws:

HiveSQLException

cancelOperation

public void cancelOperation(OperationHandle opHandle,
                            String errMsg)
                     throws HiveSQLException

Cancel the running operation unless it is already in a terminal state

Parameters:

opHandle - operation handle

errMsg - error message

Throws:

HiveSQLException

cancelOperation

public void cancelOperation(OperationHandle opHandle)
                     throws HiveSQLException

Cancel the running operation unless it is already in a terminal state

Parameters:

opHandle -

Throws:

HiveSQLException

closeOperation

public void closeOperation(OperationHandle opHandle)
                    throws HiveSQLException

Throws:

HiveSQLException

getOperationResultSetSchema

public TableSchema getOperationResultSetSchema(OperationHandle opHandle)
                                        throws HiveSQLException

Throws:

HiveSQLException

getOperationNextRowSet

public RowSet getOperationNextRowSet(OperationHandle opHandle,
                                     FetchOrientation orientation,
                                     long maxRows)
                              throws HiveSQLException

Throws:

HiveSQLException

getOperationLogRowSet

public RowSet getOperationLogRowSet(OperationHandle opHandle,
                                    FetchOrientation orientation,
                                    long maxRows,
                                    HiveConf hConf)
                             throws HiveSQLException

Throws:

HiveSQLException

getOperations

public Collection<Operation> getOperations()

removeExpiredOperations

public List<Operation> removeExpiredOperations(OperationHandle[] handles)

getHistoricalQueryInfos

public List<QueryInfo> getHistoricalQueryInfos()

Returns:

displays representing a number of historical SQLOperations, at max number of hive.server2.webui.max.historic.queries. Newest items will be first.

getLiveQueryInfos

public List<QueryInfo> getLiveQueryInfos()

Returns:

displays representing live SQLOperations

getQueryInfo

public QueryInfo getQueryInfo(String handle)

Parameters:

handle - handle of SQLOperation.

Returns:

display representing a particular SQLOperation.

getOperationByQueryId

public Operation getOperationByQueryId(String queryId)