abstract class SessionManager extends CompositeService
The SessionManager holds the all the connected Sessions, provides us the APIs to open, set, get, close Sessions and cleans idled Sessions with a daemon checker thread.
- Alphabetic
- By Inheritance
- SessionManager
- CompositeService
- AbstractService
- Logging
- Service
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
SessionManager(name: String)
- name
Service Name
Abstract Value Members
-
abstract
def
isServer: Boolean
- Attributes
- protected
- abstract def openSession(protocol: TProtocolVersion, user: String, password: String, ipAddress: String, conf: Map[String, String]): SessionHandle
- abstract def operationManager: OperationManager
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
-
var
_operationLogRoot: Option[String]
- Attributes
- protected
-
def
addService(service: Service): Unit
- Attributes
- protected
- Definition Classes
- CompositeService
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def closeSession(sessionHandle: SessionHandle): Unit
-
var
conf: KyuubiConf
- Attributes
- protected
- Definition Classes
- AbstractService
-
def
debug(message: ⇒ Any): Unit
- Definition Classes
- Logging
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
error(message: ⇒ Any): Unit
- Definition Classes
- Logging
-
def
error(message: ⇒ Any, t: Throwable): Unit
- Definition Classes
- Logging
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def getActiveCount: Int
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getConf: KyuubiConf
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
- def getExecPoolSize: Int
-
def
getName: String
Get the name of this service.
- def getOpenSessionCount: Int
-
def
getServiceState: ServiceState
Get the current service state
Get the current service state
- returns
the state of the service
- Definition Classes
- AbstractService → Service
-
def
getServices: Seq[Service]
- Definition Classes
- CompositeService
- def getSession(sessionHandle: SessionHandle): Session
- def getSessionList(): ConcurrentHashMap[SessionHandle, Session]
-
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
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
info(message: ⇒ Any): Unit
- Definition Classes
- Logging
-
def
initialize(conf: KyuubiConf): Unit
Initialize the service.
Initialize the service.
The transition must be from LATENTto INITIALIZED unless the operation failed and an exception was raised.
- conf
the configuration of the service
- Definition Classes
- SessionManager → CompositeService → AbstractService → Service
-
def
initializeLoggerIfNecessary(isInterpreter: Boolean): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def latestLogoutTime: Long
-
def
logger: Logger
- Attributes
- protected
- Definition Classes
- Logging
-
def
loggerName: String
- Attributes
- protected
- Definition Classes
- Logging
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def operationLogRoot: Option[String]
-
final
def
setSession(sessionHandle: SessionHandle, session: Session): Unit
- Attributes
- protected
-
def
start(): Unit
Start the service.
Start the service.
The transition should be from INITIALIZED to STARTED unless the operation failed and an exception was raised.
- Definition Classes
- SessionManager → CompositeService → AbstractService → Service
-
var
startTime: Long
- Attributes
- protected
- Definition Classes
- AbstractService
-
var
state: ServiceState
- Attributes
- protected
- Definition Classes
- AbstractService
-
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
- SessionManager → CompositeService → AbstractService → Service
- def submitBackgroundOperation(r: Runnable): Future[_]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
- def validateAndNormalizeConf(config: Map[String, String]): Map[String, String]
- def validateKey(key: String, value: String): Option[(String, String)]
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
warn(message: ⇒ Any, t: Throwable): Unit
- Definition Classes
- Logging
-
def
warn(message: ⇒ Any): Unit
- Definition Classes
- Logging