public class OperationManager extends AbstractService
Service.STATE
Constructor and Description |
---|
OperationManager() |
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, String statement, Map<String,String> confOverlay, boolean runAsync, long queryTimeout) throws HiveSQLException
HiveSQLException
public GetTypeInfoOperation newGetTypeInfoOperation(HiveSession parentSession)
public GetCatalogsOperation newGetCatalogsOperation(HiveSession parentSession)
public GetSchemasOperation newGetSchemasOperation(HiveSession parentSession, String catalogName, String schemaName)
public MetadataOperation newGetTablesOperation(HiveSession parentSession, String catalogName, String schemaName, String tableName, List<String> tableTypes)
public GetTableTypesOperation newGetTableTypesOperation(HiveSession parentSession)
public GetColumnsOperation newGetColumnsOperation(HiveSession parentSession, String catalogName, String schemaName, String tableName, String columnName)
public GetFunctionsOperation newGetFunctionsOperation(HiveSession parentSession, String catalogName, String schemaName, String functionName)
public GetPrimaryKeysOperation newGetPrimaryKeysOperation(HiveSession parentSession, String catalogName, String schemaName, String tableName)
public GetCrossReferenceOperation newGetCrossReferenceOperation(HiveSession session, String primaryCatalog, String primarySchema, String primaryTable, String foreignCatalog, String foreignSchema, String foreignTable)
public Operation getOperation(OperationHandle operationHandle) throws HiveSQLException
HiveSQLException
public OperationStatus getOperationStatus(OperationHandle opHandle) throws HiveSQLException
HiveSQLException
public void cancelOperation(OperationHandle opHandle) throws HiveSQLException
opHandle
- 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
public RowSet getOperationLogRowSet(OperationHandle opHandle, FetchOrientation orientation, long maxRows, HiveConf hConf) throws HiveSQLException
HiveSQLException
public Collection<Operation> getOperations()
public OperationLog getOperationLogByThread()
public List<Operation> removeExpiredOperations(OperationHandle[] handles)
public List<SQLOperationDisplay> getHistoricalSQLOperations()
public List<SQLOperationDisplay> getLiveSqlOperations()
public SQLOperationDisplay getSQLOperationDisplay(String handle)
handle
- handle of SQLOperation.Copyright © 2016 The Apache Software Foundation. All rights reserved.