public class HiveCommandOperation extends ExecuteStatementOperation
statement
backgroundHandle, confOverlay, DEFAULT_FETCH_ORIENTATION, DEFAULT_FETCH_ORIENTATION_SET, hasResultSet, isOperationLogEnabled, LOG, operationComplete, operationException, operationLog, operationStart, parentSession, QUERYID_LOG_KEY, queryState, scopeStates, SESSIONID_LOG_KEY, 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, newExecuteStatementOperation
afterRun, assertState, beforeRun, cleanupOperationLog, createOperationLog, getBackgroundHandle, getBeginTime, getHandle, getLastAccessTime, getOperationComplete, getOperationLog, getOperationStart, getOperationTimeout, getParentSession, getProtocolVersion, getState, getStatus, getTaskStatus, getType, hasResultSet, isDone, isTimedOut, markOperationCompletedTime, markOperationStartTime, onNewState, registerLoggingContext, run, setBackgroundHandle, setHasResultSet, setOperationException, setOperationTimeout, setState, shouldRunAsync, toSQLException, unregisterLoggingContext, unregisterOperationLog, updateOperationStateMetrics, validateDefaultFetchOrientation, validateFetchOrientation
protected HiveCommandOperation(HiveSession parentSession, String statement, CommandProcessor commandProcessor, Map<String,String> confOverlay)
public void runInternal() throws HiveSQLException
Operation
runInternal
in class Operation
HiveSQLException
public void close() throws HiveSQLException
close
in class Operation
HiveSQLException
public TableSchema getResultSetSchema() throws HiveSQLException
getResultSetSchema
in class Operation
HiveSQLException
public RowSet getNextRowSet(FetchOrientation orientation, long maxRows) throws HiveSQLException
getNextRowSet
in class Operation
HiveSQLException
public void cancel(OperationState stateAfterCancel) throws HiveSQLException
cancel
in class Operation
HiveSQLException
Copyright © 2021 The Apache Software Foundation. All rights reserved.