class CLIService extends CompositeService with ICLIService
CLIService.
- Alphabetic
- By Inheritance
- CLIService
- ICLIService
- CompositeService
- AbstractService
- Service
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new CLIService(hiveServer2: HiveServer2)
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 addService(service: Service): Unit
- Attributes
- protected[service]
- Definition Classes
- CompositeService
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def cancelDelegationToken(sessionHandle: SessionHandle, authFactory: HiveAuthFactory, tokenStr: String): Unit
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def cancelOperation(opHandle: OperationHandle): Unit
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def closeOperation(opHandle: OperationHandle): Unit
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def closeSession(sessionHandle: SessionHandle): Unit
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def executeStatement(sessionHandle: SessionHandle, statement: String, confOverlay: Map[String, String], queryTimeout: Long): OperationHandle
Execute statement on the server with a timeout.
Execute statement on the server with a timeout. This is a blocking call.
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def executeStatement(sessionHandle: SessionHandle, statement: String, confOverlay: Map[String, String]): OperationHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def executeStatementAsync(sessionHandle: SessionHandle, statement: String, confOverlay: Map[String, String], queryTimeout: Long): OperationHandle
Execute statement asynchronously on the server with a timeout.
Execute statement asynchronously on the server with a timeout. This is a non-blocking call
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def executeStatementAsync(sessionHandle: SessionHandle, statement: String, confOverlay: Map[String, String]): OperationHandle
Execute statement asynchronously on the server.
Execute statement asynchronously on the server. This is a non-blocking call
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def fetchResults(opHandle: OperationHandle, orientation: FetchOrientation, maxRows: Long, fetchType: FetchType): TRowSet
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def fetchResults(opHandle: OperationHandle): TRowSet
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getCatalogs(sessionHandle: SessionHandle): OperationHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getColumns(sessionHandle: SessionHandle, catalogName: String, schemaName: String, tableName: String, columnName: String): OperationHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getCrossReference(sessionHandle: SessionHandle, primaryCatalog: String, primarySchema: String, primaryTable: String, foreignCatalog: String, foreignSchema: String, foreignTable: String): OperationHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getDelegationToken(sessionHandle: SessionHandle, authFactory: HiveAuthFactory, owner: String, renewer: String): String
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getDelegationTokenFromMetaStore(owner: String): String
- def getFunctions(sessionHandle: SessionHandle, catalogName: String, schemaName: String, functionName: String): OperationHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getHiveConf(): HiveConf
Get the configuration of this service.
Get the configuration of this service. This is normally not a clone and may be manipulated, though there are no guarantees as to what the consequences of such actions may be
- returns
the current configuration, unless a specific implementation chooses otherwise.
- Definition Classes
- AbstractService → Service
- Annotations
- @Override()
- def getHttpUGI(): UserGroupInformation
- def getInfo(sessionHandle: SessionHandle, getInfoType: GetInfoType): GetInfoValue
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getName(): String
Get the name of this service.
Get the name of this service.
- returns
the service name
- Definition Classes
- AbstractService → Service
- Annotations
- @Override()
- def getOperationStatus(opHandle: OperationHandle): OperationStatus
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getPrimaryKeys(sessionHandle: SessionHandle, catalog: String, schema: String, table: String): OperationHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getQueryId(opHandle: TOperationHandle): String
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getResultSetMetadata(opHandle: OperationHandle): TTableSchema
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getSchemas(sessionHandle: SessionHandle, catalogName: String, schemaName: String): OperationHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getServiceState(): STATE
Get the current service state
Get the current service state
- returns
the state of the service
- Definition Classes
- AbstractService → Service
- Annotations
- @Override()
- def getServiceUGI(): UserGroupInformation
- def getServices(): Collection[Service]
- Definition Classes
- CompositeService
- def getSessionConf(sessionHandle: SessionHandle): HiveConf
If this is a background operation run asynchronously, we block for a configured duration, before we return (duration: HIVE_SERVER2_LONG_POLLING_TIMEOUT).
If this is a background operation run asynchronously, we block for a configured duration, before we return (duration: HIVE_SERVER2_LONG_POLLING_TIMEOUT). However, if the background operation is complete, we return immediately.
- def getSessionManager(): SessionManager
- def getStartTime(): Long
Get the service start time
Get the service start time
- returns
the start time of the service. This will be zero if the service has not yet been started.
- Definition Classes
- AbstractService → Service
- Annotations
- @Override()
- def getTableTypes(sessionHandle: SessionHandle): OperationHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getTables(sessionHandle: SessionHandle, catalogName: String, schemaName: String, tableName: String, tableTypes: List[String]): OperationHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def getTypeInfo(sessionHandle: SessionHandle): OperationHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def init(hiveConf: HiveConf): Unit
Initialize the service.
Initialize the service.
The transition must be from
STATE#NOTINITEDtoSTATE#INITEDunless the operation failed and an exception was raised.- Definition Classes
- CLIService → CompositeService → AbstractService → Service
- Annotations
- @Override()
- Exceptions thrown
IllegalStateExceptionif the current service state does not permit this action
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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 openSession(username: String, password: String, configuration: Map[String, String]): SessionHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def openSession(protocol: TProtocolVersion, username: String, password: String, ipAddress: String, configuration: Map[String, String]): SessionHandle
- def openSessionWithImpersonation(username: String, password: String, configuration: Map[String, String], delegationToken: String): SessionHandle
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def openSessionWithImpersonation(protocol: TProtocolVersion, username: String, password: String, ipAddress: String, configuration: Map[String, String], delegationToken: String): SessionHandle
- def register(l: ServiceStateChangeListener): Unit
Register an instance of the service state change events.
Register an instance of the service state change events.
- Definition Classes
- AbstractService → Service
- Annotations
- @Override()
- def removeService(service: Service): Boolean
- Attributes
- protected[service]
- Definition Classes
- CompositeService
- def renewDelegationToken(sessionHandle: SessionHandle, authFactory: HiveAuthFactory, tokenStr: String): Unit
- Definition Classes
- CLIService → ICLIService
- Annotations
- @Override()
- def start(): Unit
Start the service.
Start the service.
The transition should be from
STATE#INITEDtoSTATE#STARTEDunless the operation failed and an exception was raised.- Definition Classes
- CLIService → CompositeService → AbstractService → Service
- Annotations
- @Override()
- Exceptions thrown
IllegalStateExceptionif the current service state does not permit this action
- def stop(): Unit
Stop the service.
Stop the service.
This operation must be designed to complete regardless of the initial state of the service, including the state of all its internal fields.
- Definition Classes
- CLIService → CompositeService → AbstractService → Service
- Annotations
- @Override()
- Exceptions thrown
IllegalStateExceptionif the current service state does not permit this action
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def unregister(l: ServiceStateChangeListener): Unit
Unregister a previously instance of the service state change events.
Unregister a previously instance of the service state change events.
- Definition Classes
- AbstractService → Service
- Annotations
- @Override()
- 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)
- def openSession(protocol: TProtocolVersion, username: String, password: String, configuration: Map[String, String]): SessionHandle
- Annotations
- @Deprecated
- Deprecated
- def openSessionWithImpersonation(protocol: TProtocolVersion, username: String, password: String, configuration: Map[String, String], delegationToken: String): SessionHandle
- Annotations
- @Deprecated
- Deprecated