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

OperationManager()

Method Summary

void	cancelOperation(OperationHandle opHandle)
void	closeOperation(OperationHandle opHandle)
RowSet	getOperationNextRowSet(OperationHandle opHandle)
RowSet	getOperationNextRowSet(OperationHandle opHandle, FetchOrientation orientation, long maxRows)
TableSchema	getOperationResultSetSchema(OperationHandle opHandle)
OperationState	getOperationState(OperationHandle opHandle)
void	init(HiveConf hiveConf) Initialize the service.
ExecuteStatementOperation	newExecuteStatementOperation(Session parentSession, String statement, Map<String,String> confOverlay)
GetCatalogsOperation	newGetCatalogsOperation(Session parentSession)
GetColumnsOperation	newGetColumnsOperation(Session parentSession, String catalogName, String schemaName, String tableName, String columnName)
GetFunctionsOperation	newGetFunctionsOperation(Session parentSession, String catalogName, String schemaName, String functionName)
GetSchemasOperation	newGetSchemasOperation(Session parentSession, String catalogName, String schemaName)
MetadataOperation	newGetTablesOperation(Session parentSession, String catalogName, String schemaName, String tableName, List<String> tableTypes)
GetTableTypesOperation	newGetTableTypesOperation(Session parentSession)
GetTypeInfoOperation	newGetTypeInfoOperation(Session parentSession)
void	start() Start the service.
void	stop() Stop the service.

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

getHiveConf, getName, getServiceState, getStartTime, register, 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(Session parentSession,
                                                              String statement,
                                                              Map<String,String> confOverlay)

newGetTypeInfoOperation

public GetTypeInfoOperation newGetTypeInfoOperation(Session parentSession)

newGetCatalogsOperation

public GetCatalogsOperation newGetCatalogsOperation(Session parentSession)

newGetSchemasOperation

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

newGetTablesOperation

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

newGetTableTypesOperation

public GetTableTypesOperation newGetTableTypesOperation(Session parentSession)

newGetColumnsOperation

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

newGetFunctionsOperation

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

getOperationState

public OperationState getOperationState(OperationHandle opHandle)
                                 throws HiveSQLException

Throws:

HiveSQLException

cancelOperation

public void cancelOperation(OperationHandle opHandle)
                     throws HiveSQLException

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)
                              throws HiveSQLException

Throws:

HiveSQLException

getOperationNextRowSet

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

Throws:

HiveSQLException