org.apache.hive.service.cli.operation
Class HiveCommandOperation

java.lang.Object
  org.apache.hive.service.cli.operation.Operation
      org.apache.hive.service.cli.operation.ExecuteStatementOperation
          org.apache.hive.service.cli.operation.HiveCommandOperation

Direct Known Subclasses:

AddResourceOperation, DeleteResourceOperation, DfsOperation, SetOperation

public abstract class HiveCommandOperation
extends ExecuteStatementOperation

HiveCommandOperation.

Field Summary

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

confOverlay, statement

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

DEFAULT_FETCH_MAX_ROWS, hasResultSet, LOG, parentSession

Constructor Summary

protected

HiveCommandOperation(Session parentSession, String statement, Map<String,String> confOverlay)

Method Summary

void	close()
protected CommandProcessor	getCommandProcessor()
RowSet	getNextRowSet(FetchOrientation orientation, long maxRows)
TableSchema	getResultSetSchema()
void	run()
protected void	setCommandProcessor(CommandProcessor commandProcessor)

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

getStatement, newExecuteStatementOperation

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

assertState, cancel, getConfiguration, getHandle, getNextRowSet, getParentSession, getState, getType, hasResultSet, isCanceled, isFailed, isFinished, isRunning, setConfiguration, setHasResultSet, setState

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveCommandOperation

protected HiveCommandOperation(Session parentSession,
                               String statement,
                               Map<String,String> confOverlay)

Method Detail

run

public void run()
         throws HiveSQLException

Specified by:

run 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

getCommandProcessor

protected CommandProcessor getCommandProcessor()

setCommandProcessor

protected void setCommandProcessor(CommandProcessor commandProcessor)