Packages

class HiveSessionImpl extends HiveSession

HiveSession

Linear Supertypes
HiveSession, HiveSessionBase, AnyRef, Any
Known Subclasses
HiveSessionImplwithUGI
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. HiveSessionImpl
  2. HiveSession
  3. HiveSessionBase
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new HiveSessionImpl(protocol: TProtocolVersion, username: String, password: String, serverhiveConf: HiveConf, ipAddress: String)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def acquire(userAccess: Boolean): Unit
    Attributes
    protected[session]
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def cancelDelegationToken(authFactory: HiveAuthFactory, tokenStr: String): Unit
    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
  7. def cancelOperation(opHandle: OperationHandle): Unit
    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  9. def close(): Unit

    close the session

    close the session

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  10. def closeExpiredOperations(): Unit
    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
  11. def closeOperation(opHandle: OperationHandle): Unit
    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  14. def executeStatement(statement: String, confOverlay: Map[String, String], queryTimeout: Long): OperationHandle

    execute operation handler

    execute operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  15. def executeStatement(statement: String, confOverlay: Map[String, String]): OperationHandle

    execute operation handler

    execute operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  16. def executeStatementAsync(statement: String, confOverlay: Map[String, String], queryTimeout: Long): OperationHandle

    execute operation handler

    execute operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  17. def executeStatementAsync(statement: String, confOverlay: Map[String, String]): OperationHandle

    execute operation handler

    execute operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  18. def fetchResults(opHandle: OperationHandle, orientation: FetchOrientation, maxRows: Long, fetchType: FetchType): TRowSet
    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
  19. def getCatalogs(): OperationHandle

    getCatalogs operation handler

    getCatalogs operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  20. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  21. def getColumns(catalogName: String, schemaName: String, tableName: String, columnName: String): OperationHandle

    getColumns operation handler

    getColumns operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  22. def getCrossReference(primaryCatalog: String, primarySchema: String, primaryTable: String, foreignCatalog: String, foreignSchema: String, foreignTable: String): OperationHandle

    getCrossReference operation handler

    getCrossReference operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  23. def getDelegationToken(authFactory: HiveAuthFactory, owner: String, renewer: String): String
    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
  24. def getFunctions(catalogName: String, schemaName: String, functionName: String): OperationHandle

    getFunctions operation handler

    getFunctions operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  25. def getHiveConf(): HiveConf
    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  26. def getInfo(getInfoType: GetInfoType): GetInfoValue

    getInfo operation handler

    getInfo operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  27. def getIpAddress(): String
    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  28. def getLastAccessTime(): Long
    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  29. def getMetaStoreClient(): IMetaStoreClient
    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
  30. def getNoOperationTime(): Long
    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
  31. def getOperationLogSessionDir(): File

    Get the session dir, which is the parent dir of operation logs

    Get the session dir, which is the parent dir of operation logs

    returns

    a file representing the parent directory of operation logs

    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  32. def getPassword(): String
    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  33. def getPrimaryKeys(catalog: String, schema: String, table: String): OperationHandle

    getPrimaryKeys operation handler

    getPrimaryKeys operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  34. def getProtocolVersion(): TProtocolVersion
    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  35. def getResultSetMetadata(opHandle: OperationHandle): TTableSchema
    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
  36. def getSchemas(catalogName: String, schemaName: String): OperationHandle

    getSchemas operation handler

    getSchemas operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  37. def getSession(): HiveSession
    Attributes
    protected[session]
  38. def getSessionHandle(): SessionHandle
    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  39. def getSessionManager(): SessionManager

    Get the session manager for the session

    Get the session manager for the session

    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  40. def getSessionState(): SessionState
    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  41. def getTableTypes(): OperationHandle

    getTableTypes operation handler

    getTableTypes operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  42. def getTables(catalogName: String, schemaName: String, tableName: String, tableTypes: List[String]): OperationHandle

    getTables operation handler

    getTables operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  43. def getTypeInfo(): OperationHandle

    getTypeInfo operation handler

    getTypeInfo operation handler

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
    Exceptions thrown
  44. def getUserName(): String
    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  45. def getUsername(): String
    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  46. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  47. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  48. def isOperationLogEnabled(): Boolean

    Check whether operation logging is enabled and session dir is created successfully

    Check whether operation logging is enabled and session dir is created successfully

    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  49. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  50. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  51. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  52. def open(sessionConfMap: Map[String, String]): Unit

    Opens a new HiveServer2 session for the client connection.

    Opens a new HiveServer2 session for the client connection. Creates a new SessionState object that will be associated with this HiveServer2 session. When the server executes multiple queries in the same session, this SessionState object is reused across multiple queries. Note that if doAs is true, this call goes through a proxy object, which wraps the method logic in a UserGroupInformation#doAs. That's why it is important to create SessionState here rather than in the constructor.

    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
  53. def release(userAccess: Boolean): Unit

    1.

    1. We'll remove the ThreadLocal SessionState as this thread might now serve other requests. 2. We'll cache the ThreadLocal RawStore object for this background thread for an orderly cleanup when this thread is garbage collected later.

    Attributes
    protected[session]
    See also

    org.apache.hive.service.server.ThreadWithGarbageCleanup#finalize()

  54. def renewDelegationToken(authFactory: HiveAuthFactory, tokenStr: String): Unit
    Definition Classes
    HiveSessionImpl → HiveSession
    Annotations
    @Override()
  55. def setIpAddress(ipAddress: String): Unit
    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  56. def setOperationLogSessionDir(operationLogRootDir: File): Unit

    Set the session dir, which is the parent dir of operation logs

    Set the session dir, which is the parent dir of operation logs

    operationLogRootDir

    the parent dir of the session dir

    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  57. def setOperationManager(operationManager: OperationManager): Unit

    Set operation manager for the session

    Set operation manager for the session

    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  58. def setSessionManager(sessionManager: SessionManager): Unit

    Set the session manager for the session

    Set the session manager for the session

    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  59. def setUserName(userName: String): Unit
    Definition Classes
    HiveSessionImpl → HiveSessionBase
    Annotations
    @Override()
  60. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  61. def toString(): String
    Definition Classes
    AnyRef → Any
  62. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  63. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  64. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from HiveSession

Inherited from HiveSessionBase

Inherited from AnyRef

Inherited from Any

Ungrouped