public class OperationManager extends AbstractService
Service.STATE
Constructor and Description |
---|
OperationManager() |
Modifier and Type | Method and Description |
---|---|
void |
cancelOperation(OperationHandle opHandle) |
void |
closeOperation(OperationHandle opHandle) |
Operation |
getOperation(OperationHandle operationHandle) |
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(HiveSession parentSession,
java.lang.String statement,
java.util.Map<java.lang.String,java.lang.String> confOverlay,
boolean runAsync) |
GetCatalogsOperation |
newGetCatalogsOperation(HiveSession parentSession) |
GetColumnsOperation |
newGetColumnsOperation(HiveSession parentSession,
java.lang.String catalogName,
java.lang.String schemaName,
java.lang.String tableName,
java.lang.String columnName) |
GetFunctionsOperation |
newGetFunctionsOperation(HiveSession parentSession,
java.lang.String catalogName,
java.lang.String schemaName,
java.lang.String functionName) |
GetSchemasOperation |
newGetSchemasOperation(HiveSession parentSession,
java.lang.String catalogName,
java.lang.String schemaName) |
MetadataOperation |
newGetTablesOperation(HiveSession parentSession,
java.lang.String catalogName,
java.lang.String schemaName,
java.lang.String tableName,
java.util.List<java.lang.String> tableTypes) |
GetTableTypesOperation |
newGetTableTypesOperation(HiveSession parentSession) |
GetTypeInfoOperation |
newGetTypeInfoOperation(HiveSession parentSession) |
void |
start()
Start the service.
|
void |
stop()
Stop the service.
|
getHiveConf, getName, getServiceState, getStartTime, register, unregister
public void init(HiveConf hiveConf)
AbstractService
Service.STATE.NOTINITED
to Service.STATE.INITED
unless the
operation failed and an exception was raised.init
in interface Service
init
in class AbstractService
public void start()
AbstractService
Service.STATE.INITED
to Service.STATE.STARTED
unless the
operation failed and an exception was raised.start
in interface Service
start
in class AbstractService
public void stop()
AbstractService
stop
in interface Service
stop
in class AbstractService
public ExecuteStatementOperation newExecuteStatementOperation(HiveSession parentSession, java.lang.String statement, java.util.Map<java.lang.String,java.lang.String> confOverlay, boolean runAsync)
public GetTypeInfoOperation newGetTypeInfoOperation(HiveSession parentSession)
public GetCatalogsOperation newGetCatalogsOperation(HiveSession parentSession)
public GetSchemasOperation newGetSchemasOperation(HiveSession parentSession, java.lang.String catalogName, java.lang.String schemaName)
public MetadataOperation newGetTablesOperation(HiveSession parentSession, java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, java.util.List<java.lang.String> tableTypes)
public GetTableTypesOperation newGetTableTypesOperation(HiveSession parentSession)
public GetColumnsOperation newGetColumnsOperation(HiveSession parentSession, java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, java.lang.String columnName)
public GetFunctionsOperation newGetFunctionsOperation(HiveSession parentSession, java.lang.String catalogName, java.lang.String schemaName, java.lang.String functionName)
public Operation getOperation(OperationHandle operationHandle) throws HiveSQLException
HiveSQLException
public OperationState getOperationState(OperationHandle opHandle) throws HiveSQLException
HiveSQLException
public void cancelOperation(OperationHandle opHandle) throws HiveSQLException
HiveSQLException
public void closeOperation(OperationHandle opHandle) throws HiveSQLException
HiveSQLException
public TableSchema getOperationResultSetSchema(OperationHandle opHandle) throws HiveSQLException
HiveSQLException
public RowSet getOperationNextRowSet(OperationHandle opHandle) throws HiveSQLException
HiveSQLException
public RowSet getOperationNextRowSet(OperationHandle opHandle, FetchOrientation orientation, long maxRows) throws HiveSQLException
HiveSQLException
Copyright © 2012 The Apache Software Foundation