org.apache.hive.service.cli.session

Class SessionManager

java.lang.Object

org.apache.hive.service.AbstractService

org.apache.hive.service.CompositeService

org.apache.hive.service.cli.session.SessionManager

All Implemented Interfaces:

Service

public class SessionManager
extends CompositeService

SessionManager.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hive.service.CompositeService

CompositeService.CompositeServiceShutdownHook

Nested classes/interfaces inherited from interface org.apache.hive.service.Service

Service.STATE

Field Summary

Fields

Modifier and Type	Field and Description
static String	HIVERCFILE

Constructor Summary

Constructors

Constructor and Description
SessionManager(HiveServer2 hiveServer2)

Method Summary

Modifier and Type	Method and Description
static void	clearForwardedAddresses()
static void	clearIpAddress()
static void	clearProxyUserName()
static void	clearUserName()
void	closeSession(SessionHandle sessionHandle)
HiveSession	createSession(SessionHandle sessionHandle, org.apache.hive.service.rpc.thrift.TProtocolVersion protocol, String username, String password, String ipAddress, Map<String,String> sessionConf, boolean withImpersonation, String delegationToken)
static List<String>	getForwardedAddresses()
String	getHiveServer2HostName()
static String	getIpAddress()
int	getOpenSessionCount()
OperationManager	getOperationManager()
Collection<Operation>	getOperations()
static String	getProxyUserName()
HiveSession	getSession(SessionHandle sessionHandle)
Collection<HiveSession>	getSessions()
static String	getUserName()
void	init(HiveConf hiveConf) Initialize the service.
SessionHandle	openSession(org.apache.hive.service.rpc.thrift.TProtocolVersion protocol, String username, String password, String ipAddress, Map<String,String> sessionConf)
SessionHandle	openSession(org.apache.hive.service.rpc.thrift.TProtocolVersion protocol, String username, String password, String ipAddress, Map<String,String> sessionConf, boolean withImpersonation, String delegationToken) Opens a new session and creates a session handle.
static void	setForwardedAddresses(List<String> ipAddress)
static void	setIpAddress(String ipAddress)
static void	setProxyUserName(String userName)
static void	setUserName(String userName)
void	start() Start the service.
void	stop() Stop the service.
Future<?>	submitBackgroundOperation(Runnable r)

Methods inherited from class org.apache.hive.service.CompositeService

addService, getServices, removeService

Methods inherited from class org.apache.hive.service.AbstractService

getHiveConf, getName, getServiceState, getStartTime, register, setHiveConf, unregister

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

HIVERCFILE

public static final String HIVERCFILE

See Also:

Constant Field Values

Constructor Detail

SessionManager

public SessionManager(HiveServer2 hiveServer2)

Method Detail

init

public void init(HiveConf hiveConf)

Description copied from class: AbstractService

Initialize the service. The transition must be from Service.STATE.NOTINITED to Service.STATE.INITED unless the operation failed and an exception was raised.

Specified by:

init in interface Service

Overrides:

init in class CompositeService

start

public void start()

Description copied from class: AbstractService

Start the service. The transition should be from Service.STATE.INITED to Service.STATE.STARTED unless the operation failed and an exception was raised.

Specified by:

start in interface Service

Overrides:

start in class CompositeService

stop

public void stop()

Description copied from class: AbstractService

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.

Specified by:

stop in interface Service

Overrides:

stop in class CompositeService

openSession

public SessionHandle openSession(org.apache.hive.service.rpc.thrift.TProtocolVersion protocol,
                                 String username,
                                 String password,
                                 String ipAddress,
                                 Map<String,String> sessionConf)
                          throws HiveSQLException

Throws:

HiveSQLException

openSession

public SessionHandle openSession(org.apache.hive.service.rpc.thrift.TProtocolVersion protocol,
                                 String username,
                                 String password,
                                 String ipAddress,
                                 Map<String,String> sessionConf,
                                 boolean withImpersonation,
                                 String delegationToken)
                          throws HiveSQLException

Opens a new session and creates a session handle. The username passed to this method is the effective username. If withImpersonation is true (==doAs true) we wrap all the calls in HiveSession within a UGI.doAs, where UGI corresponds to the effective user.

Parameters:

protocol -

username -

password -

ipAddress -

sessionConf -

withImpersonation -

delegationToken -

Returns:

Throws:

HiveSQLException

See Also:

ThriftCLIService.getUserName(TOpenSessionReq)

createSession

public HiveSession createSession(SessionHandle sessionHandle,
                                 org.apache.hive.service.rpc.thrift.TProtocolVersion protocol,
                                 String username,
                                 String password,
                                 String ipAddress,
                                 Map<String,String> sessionConf,
                                 boolean withImpersonation,
                                 String delegationToken)
                          throws HiveSQLException

Throws:

HiveSQLException

closeSession

public void closeSession(SessionHandle sessionHandle)
                  throws HiveSQLException

Throws:

HiveSQLException

getSession

public HiveSession getSession(SessionHandle sessionHandle)
                       throws HiveSQLException

Throws:

HiveSQLException

getOperationManager

public OperationManager getOperationManager()

setIpAddress

public static void setIpAddress(String ipAddress)

clearIpAddress

public static void clearIpAddress()

getIpAddress

public static String getIpAddress()

setForwardedAddresses

public static void setForwardedAddresses(List<String> ipAddress)

clearForwardedAddresses

public static void clearForwardedAddresses()

getForwardedAddresses

public static List<String> getForwardedAddresses()

setUserName

public static void setUserName(String userName)

clearUserName

public static void clearUserName()

getUserName

public static String getUserName()

setProxyUserName

public static void setProxyUserName(String userName)

getProxyUserName

public static String getProxyUserName()

clearProxyUserName

public static void clearProxyUserName()

submitBackgroundOperation

public Future<?> submitBackgroundOperation(Runnable r)

getOperations

public Collection<Operation> getOperations()

getSessions

public Collection<HiveSession> getSessions()

getOpenSessionCount

public int getOpenSessionCount()

getHiveServer2HostName

public String getHiveServer2HostName()
                              throws Exception

Throws:

Exception