public class SQLOperation extends ExecuteStatementOperation
confOverlay, statementbackgroundHandle, 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, setConfOverlayafterRun, 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, validateFetchOrientationpublic SQLOperation(HiveSession parentSession, String statement, Map<String,String> confOverlay, boolean runInBackground)
public void prepare(HiveConf sqlOperationConf) throws HiveSQLException
sqlOperationConf - HiveSQLExceptionpublic void runInternal()
throws HiveSQLException
OperationrunInternal in class OperationHiveSQLExceptionpublic void cancel()
throws HiveSQLException
cancel 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 OperationHiveSQLExceptionCopyright © 2017 The Apache Software Foundation. All rights reserved.