abstract class Operation extends AnyRef
- Alphabetic
- By Inheritance
- Operation
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Operation(parentSession: HiveSession, confOverlay: Map[String, String], opType: OperationType, runInBackground: Boolean)
- Attributes
- protected[operation]
- new Operation(parentSession: HiveSession, confOverlay: Map[String, String], opType: OperationType)
- Attributes
- protected[operation]
- new Operation(parentSession: HiveSession, opType: OperationType)
- Attributes
- protected[operation]
Abstract Value Members
- abstract def getNextRowSet(orientation: FetchOrientation, maxRows: Long): TRowSet
- abstract def getResultSetSchema(): TTableSchema
- abstract def runInternal(): Unit
Implemented by subclass of Operation class to execute specific behaviors.
Implemented by subclass of Operation class to execute specific behaviors.
- Attributes
- protected[operation]
- Exceptions thrown
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def afterRun(): Unit
Invoked after runInternal(), even if an exception is thrown in runInternal().
Invoked after runInternal(), even if an exception is thrown in runInternal(). Clean up resources, which was set up in beforeRun().
- Attributes
- protected[operation]
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- final def assertState(state: OperationState): Unit
- Attributes
- protected[operation]
- def beforeRun(): Unit
Invoked before runInternal().
Invoked before runInternal(). Set up some preconditions, or configurations.
- Attributes
- protected[operation]
- def cancel(): Unit
- def cleanupOperationLog(): Unit
- Attributes
- protected[operation]
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def close(): Unit
- def createOperationLog(): Unit
- Attributes
- protected[operation]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def getBackgroundHandle(): Future[_ <: AnyRef]
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getConfOverlay(): Map[String, String]
- Attributes
- protected[operation]
- def getConfiguration(): HiveConf
- def getHandle(): OperationHandle
- def getLastAccessTime(): Long
- def getOperationLog(): OperationLog
- def getOperationTimeout(): Long
- def getParentSession(): HiveSession
- def getProtocolVersion(): TProtocolVersion
- def getStatus(): OperationStatus
- def getType(): OperationType
- def hasResultSet(): Boolean
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def isCanceled(): Boolean
- def isFailed(): Boolean
- def isFinished(): Boolean
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isRunning(): Boolean
- def isTimedOut(current: Long): Boolean
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def run(): Unit
- def setBackgroundHandle(backgroundHandle: Future[_ <: AnyRef]): Unit
- Attributes
- protected[operation]
- def setConfiguration(configuration: HiveConf): Unit
- def setHasResultSet(hasResultSet: Boolean): Unit
- Attributes
- protected[operation]
- def setOperationException(operationException: HiveSQLException): Unit
- Attributes
- protected[operation]
- def setOperationTimeout(operationTimeout: Long): Unit
- final def setState(newState: OperationState): OperationState
- Attributes
- protected[operation]
- def shouldRunAsync(): Boolean
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toSQLException(prefix: String, response: CommandProcessorResponse): HiveSQLException
- Attributes
- protected[operation]
- def toString(): String
- Definition Classes
- AnyRef → Any
- def unregisterOperationLog(): Unit
- Attributes
- protected[operation]
- def validateDefaultFetchOrientation(orientation: FetchOrientation): Unit
Verify if the given fetch orientation is part of the default orientation types.
Verify if the given fetch orientation is part of the default orientation types.
- Attributes
- protected[operation]
- Exceptions thrown
- def validateFetchOrientation(orientation: FetchOrientation, supportedOrientations: EnumSet[FetchOrientation]): Unit
Verify if the given fetch orientation is part of the supported orientation types.
Verify if the given fetch orientation is part of the supported orientation types.
- Attributes
- protected[operation]
- Exceptions thrown
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)