public abstract class Operation
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_FETCH_MAX_ROWS |
protected boolean |
hasResultSet |
static org.apache.commons.logging.Log |
LOG |
protected HiveSession |
parentSession |
Modifier | Constructor and Description |
---|---|
protected |
Operation(HiveSession parentSession,
OperationType opType) |
Modifier and Type | Method and Description |
---|---|
protected void |
assertState(OperationState state) |
void |
cancel() |
abstract void |
close() |
HiveConf |
getConfiguration() |
OperationHandle |
getHandle() |
RowSet |
getNextRowSet() |
abstract RowSet |
getNextRowSet(FetchOrientation orientation,
long maxRows) |
HiveSession |
getParentSession() |
abstract TableSchema |
getResultSetSchema() |
OperationState |
getState() |
OperationType |
getType() |
boolean |
hasResultSet() |
boolean |
isCanceled() |
boolean |
isFailed() |
boolean |
isFinished() |
boolean |
isRunning() |
abstract void |
run() |
void |
setConfiguration(HiveConf configuration) |
protected void |
setHasResultSet(boolean hasResultSet) |
protected OperationState |
setState(OperationState newState) |
protected final HiveSession parentSession
public static final org.apache.commons.logging.Log LOG
public static final long DEFAULT_FETCH_MAX_ROWS
protected boolean hasResultSet
protected Operation(HiveSession parentSession, OperationType opType)
public void setConfiguration(HiveConf configuration)
public HiveConf getConfiguration()
public HiveSession getParentSession()
public OperationHandle getHandle()
public OperationType getType()
public OperationState getState()
public boolean hasResultSet()
protected void setHasResultSet(boolean hasResultSet)
protected final OperationState setState(OperationState newState) throws HiveSQLException
HiveSQLException
protected final void assertState(OperationState state) throws HiveSQLException
HiveSQLException
public boolean isRunning()
public boolean isFinished()
public boolean isCanceled()
public boolean isFailed()
public abstract void run() throws HiveSQLException
HiveSQLException
public void cancel() throws HiveSQLException
HiveSQLException
public abstract void close() throws HiveSQLException
HiveSQLException
public abstract TableSchema getResultSetSchema() throws HiveSQLException
HiveSQLException
public abstract RowSet getNextRowSet(FetchOrientation orientation, long maxRows) throws HiveSQLException
HiveSQLException
public RowSet getNextRowSet() throws HiveSQLException
HiveSQLException
Copyright © 2012 The Apache Software Foundation