public class SQLOperation extends ExecuteStatementOperation
confOverlay, statement
backgroundHandle, DEFAULT_FETCH_MAX_ROWS, DEFAULT_FETCH_ORIENTATION, DEFAULT_FETCH_ORIENTATION_SET, hasResultSet, isOperationLogEnabled, LOG, operationException, operationLog, parentSession, runAsync
Constructor and Description |
---|
SQLOperation(HiveSession parentSession,
String statement,
Map<String,String> confOverlay,
boolean runInBackground) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
void |
close() |
RowSet |
getNextRowSet(FetchOrientation orientation,
long maxRows) |
TableSchema |
getResultSetSchema() |
void |
prepare(HiveConf sqlOperationConf)
Compile the query and extract metadata
|
void |
runInternal()
Implemented by subclass of Operation class to execute specific behaviors.
|
getConfOverlay, getStatement, newExecuteStatementOperation, setConfOverlay
afterRun, assertState, beforeRun, cleanupOperationLog, createOperationLog, getBackgroundHandle, getConfiguration, getHandle, getLastAccessTime, getNextRowSet, getOperationLog, getOperationTimeout, getParentSession, getProtocolVersion, getStatus, getType, hasResultSet, isCanceled, isFailed, isFinished, isRunning, isTimedOut, run, setBackgroundHandle, setConfiguration, setHasResultSet, setOperationException, setOperationTimeout, setState, shouldRunAsync, toSQLException, unregisterOperationLog, validateDefaultFetchOrientation, validateFetchOrientation
public SQLOperation(HiveSession parentSession, String statement, Map<String,String> confOverlay, boolean runInBackground)
public void prepare(HiveConf sqlOperationConf) throws HiveSQLException
sqlOperationConf
- HiveSQLException
public void runInternal() throws HiveSQLException
Operation
runInternal
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 © 2017 The Apache Software Foundation. All rights reserved.