public class SessionManager extends CompositeService
CompositeService.CompositeServiceShutdownHook
Service.STATE
Constructor and Description |
---|
SessionManager() |
Modifier and Type | Method and Description |
---|---|
void |
closeSession(SessionHandle sessionHandle) |
OperationManager |
getOperationManager() |
HiveSession |
getSession(SessionHandle sessionHandle) |
void |
init(HiveConf hiveConf)
Initialize the service.
|
SessionHandle |
openSession(java.lang.String username,
java.lang.String password,
java.util.Map<java.lang.String,java.lang.String> sessionConf) |
SessionHandle |
openSession(java.lang.String username,
java.lang.String password,
java.util.Map<java.lang.String,java.lang.String> sessionConf,
boolean withImpersonation,
java.lang.String delegationToken) |
static void |
setIpAddress(java.lang.String ipAddress) |
static void |
setUserName(java.lang.String userName) |
void |
start()
Start the service.
|
void |
stop()
Stop the service.
|
java.util.concurrent.Future<?> |
submitBackgroundOperation(java.lang.Runnable r) |
addService, getServices, removeService
getHiveConf, getName, getServiceState, getStartTime, register, unregister
public void init(HiveConf hiveConf)
AbstractService
Service.STATE.NOTINITED
to Service.STATE.INITED
unless the
operation failed and an exception was raised.init
in interface Service
init
in class CompositeService
public void start()
AbstractService
Service.STATE.INITED
to Service.STATE.STARTED
unless the
operation failed and an exception was raised.start
in interface Service
start
in class CompositeService
public void stop()
AbstractService
stop
in interface Service
stop
in class CompositeService
public SessionHandle openSession(java.lang.String username, java.lang.String password, java.util.Map<java.lang.String,java.lang.String> sessionConf) throws HiveSQLException
HiveSQLException
public SessionHandle openSession(java.lang.String username, java.lang.String password, java.util.Map<java.lang.String,java.lang.String> sessionConf, boolean withImpersonation, java.lang.String delegationToken) throws HiveSQLException
HiveSQLException
public void closeSession(SessionHandle sessionHandle) throws HiveSQLException
HiveSQLException
public HiveSession getSession(SessionHandle sessionHandle) throws HiveSQLException
HiveSQLException
public OperationManager getOperationManager()
public static void setIpAddress(java.lang.String ipAddress)
public static void setUserName(java.lang.String userName)
public java.util.concurrent.Future<?> submitBackgroundOperation(java.lang.Runnable r)
Copyright © 2012 The Apache Software Foundation