public abstract class HiveCommandOperation extends ExecuteStatementOperation
confOverlay, statement
DEFAULT_FETCH_MAX_ROWS, hasResultSet, LOG, parentSession
Modifier | Constructor and Description |
---|---|
protected |
HiveCommandOperation(HiveSession parentSession,
java.lang.String statement,
java.util.Map<java.lang.String,java.lang.String> confOverlay) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected CommandProcessor |
getCommandProcessor() |
RowSet |
getNextRowSet(FetchOrientation orientation,
long maxRows) |
TableSchema |
getResultSetSchema() |
void |
run() |
protected void |
setCommandProcessor(CommandProcessor commandProcessor) |
getStatement, newExecuteStatementOperation
assertState, cancel, getConfiguration, getHandle, getNextRowSet, getParentSession, getState, getType, hasResultSet, isCanceled, isFailed, isFinished, isRunning, setConfiguration, setHasResultSet, setState
protected HiveCommandOperation(HiveSession parentSession, java.lang.String statement, java.util.Map<java.lang.String,java.lang.String> confOverlay)
public void run() throws HiveSQLException
run
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
protected CommandProcessor getCommandProcessor()
protected void setCommandProcessor(CommandProcessor commandProcessor)
Copyright © 2012 The Apache Software Foundation