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