public class HiveCommandOperation extends ExecuteStatementOperation
statementbackgroundHandle, DEFAULT_FETCH_ORIENTATION, DEFAULT_FETCH_ORIENTATION_SET, hasResultSet, isOperationLogEnabled, LOG, operationComplete, operationException, operationLog, operationStart, parentSession, queryState, scopeStates, terminalStates| Modifier | Constructor and Description |
|---|---|
protected |
HiveCommandOperation(HiveSession parentSession,
String statement,
CommandProcessor commandProcessor,
Map<String,String> confOverlay) |
| Modifier and Type | Method and Description |
|---|---|
void |
cancel(OperationState stateAfterCancel) |
void |
close() |
RowSet |
getNextRowSet(FetchOrientation orientation,
long maxRows) |
TableSchema |
getResultSetSchema() |
void |
runInternal()
Implemented by subclass of Operation class to execute specific behaviors.
|
getStatement, newExecuteStatementOperationafterRun, assertState, beforeRun, cleanupOperationLog, createOperationLog, getBackgroundHandle, getBeginTime, getHandle, getLastAccessTime, getOperationComplete, getOperationLog, getOperationStart, getOperationTimeout, getParentSession, getProtocolVersion, getState, getStatus, getTaskStatus, getType, hasResultSet, isDone, isTimedOut, markOperationCompletedTime, markOperationStartTime, onNewState, run, setBackgroundHandle, setHasResultSet, setOperationException, setOperationTimeout, setState, shouldRunAsync, toSQLException, updateOperationStateMetrics, validateDefaultFetchOrientation, validateFetchOrientationprotected HiveCommandOperation(HiveSession parentSession, String statement, CommandProcessor commandProcessor, Map<String,String> confOverlay)
public void runInternal()
throws HiveSQLException
OperationrunInternal in class OperationHiveSQLExceptionpublic void close()
throws HiveSQLException
close in class OperationHiveSQLExceptionpublic TableSchema getResultSetSchema() throws HiveSQLException
getResultSetSchema in class OperationHiveSQLExceptionpublic RowSet getNextRowSet(FetchOrientation orientation, long maxRows) throws HiveSQLException
getNextRowSet in class OperationHiveSQLExceptionpublic void cancel(OperationState stateAfterCancel) throws HiveSQLException
cancel in class OperationHiveSQLExceptionCopyright © 2019 The Apache Software Foundation. All Rights Reserved.