org.apache.hive.service.cli.operation

Class SQLOperation

java.lang.Object

org.apache.hive.service.cli.operation.Operation

org.apache.hive.service.cli.operation.ExecuteStatementOperation

org.apache.hive.service.cli.operation.SQLOperation

public class SQLOperation
extends ExecuteStatementOperation

SQLOperation.

Field Summary

Fields inherited from class org.apache.hive.service.cli.operation.ExecuteStatementOperation

statement

Fields inherited from class org.apache.hive.service.cli.operation.Operation

backgroundHandle, confOverlay, DEFAULT_FETCH_MAX_ROWS, DEFAULT_FETCH_ORIENTATION, DEFAULT_FETCH_ORIENTATION_SET, hasResultSet, isOperationLogEnabled, LOG, operationComplete, operationException, operationLog, operationStart, parentSession, QUERYID_LOG_KEY, queryState, scopeStates, SESSIONID_LOG_KEY, terminalStates

Constructor Summary

Constructors

Constructor and Description
SQLOperation(HiveSession parentSession, String statement, Map<String,String> confOverlay, boolean runInBackground, long queryTimeout)

Method Summary

Modifier and Type	Method and Description
void	cancel(OperationState stateAfterCancel)
void	close()
String	getExecutionEngine()
RowSet	getNextRowSet(FetchOrientation orientation, long maxRows)
TableSchema	getResultSetSchema()
SQLOperationDisplay	getSQLOperationDisplay() Get summary information of this SQLOperation for display in WebUI.
String	getTaskStatus()
protected void	onNewState(OperationState state, OperationState prevState)
void	prepare(QueryState queryState) Compile the query and extract metadata
void	runInternal() Implemented by subclass of Operation class to execute specific behaviors.
boolean	shouldRunAsync()

Methods inherited from class org.apache.hive.service.cli.operation.ExecuteStatementOperation

getStatement, newExecuteStatementOperation

Methods inherited from class org.apache.hive.service.cli.operation.Operation

afterRun, assertState, beforeRun, cleanupOperationLog, createOperationLog, getBackgroundHandle, getBeginTime, getHandle, getLastAccessTime, getNextRowSet, getOperationComplete, getOperationLog, getOperationStart, getOperationTimeout, getParentSession, getProtocolVersion, getState, getStatus, getType, hasResultSet, isCanceled, isFailed, isFinished, isRunning, isTimedOut, markOperationCompletedTime, markOperationStartTime, registerLoggingContext, run, setBackgroundHandle, setHasResultSet, setMetrics, setOperationException, setOperationTimeout, setState, toSQLException, unregisterLoggingContext, unregisterOperationLog, validateDefaultFetchOrientation, validateFetchOrientation

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SQLOperation

public SQLOperation(HiveSession parentSession,
                    String statement,
                    Map<String,String> confOverlay,
                    boolean runInBackground,
                    long queryTimeout)

Method Detail

shouldRunAsync

public boolean shouldRunAsync()

Overrides:

shouldRunAsync in class Operation

prepare

public void prepare(QueryState queryState)
             throws HiveSQLException

Compile the query and extract metadata

Parameters:

sqlOperationConf -

Throws:

HiveSQLException

runInternal

public void runInternal()
                 throws HiveSQLException

Description copied from class: Operation

Implemented by subclass of Operation class to execute specific behaviors.

Specified by:

runInternal in class Operation

Throws:

HiveSQLException

cancel

public void cancel(OperationState stateAfterCancel)
            throws HiveSQLException

Specified by:

cancel in class Operation

Throws:

HiveSQLException

close

public void close()
           throws HiveSQLException

Specified by:

close in class Operation

Throws:

HiveSQLException

getResultSetSchema

public TableSchema getResultSetSchema()
                               throws HiveSQLException

Specified by:

getResultSetSchema in class Operation

Throws:

HiveSQLException

getNextRowSet

public RowSet getNextRowSet(FetchOrientation orientation,
                            long maxRows)
                     throws HiveSQLException

Specified by:

getNextRowSet in class Operation

Throws:

HiveSQLException

getTaskStatus

public String getTaskStatus()
                     throws HiveSQLException

Overrides:

getTaskStatus in class Operation

Throws:

HiveSQLException

getSQLOperationDisplay

public SQLOperationDisplay getSQLOperationDisplay()

Get summary information of this SQLOperation for display in WebUI.

onNewState

protected void onNewState(OperationState state,
                          OperationState prevState)

Overrides:

onNewState in class Operation

getExecutionEngine

public String getExecutionEngine()