public abstract class HiveCommandOperation extends ExecuteStatementOperation
confOverlay, statementDEFAULT_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, newExecuteStatementOperationassertState, cancel, getConfiguration, getHandle, getNextRowSet, getParentSession, getState, getType, hasResultSet, isCanceled, isFailed, isFinished, isRunning, setConfiguration, setHasResultSet, setStateprotected 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 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 OperationHiveSQLExceptionprotected CommandProcessor getCommandProcessor()
protected void setCommandProcessor(CommandProcessor commandProcessor)
Copyright © 2012 The Apache Software Foundation