org.apache.lens.server.session

Class HiveSessionService

java.lang.Object

org.apache.hive.service.AbstractService

org.apache.hive.service.CompositeService

org.apache.lens.server.BaseLensService

org.apache.lens.server.session.HiveSessionService

All Implemented Interfaces:

Externalizable, Serializable, org.apache.hive.service.Service, HealthCheckable, LensService, SessionService

public class HiveSessionService
extends BaseLensService
implements SessionService

The Class HiveSessionService.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	HiveSessionService.SessionExpiryRunnable The Class SessionExpiryRunnable.

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

org.apache.hive.service.CompositeService.CompositeServiceShutdownHook

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

org.apache.hive.service.Service.STATE

Field Summary

Fields inherited from interface org.apache.lens.server.api.session.SessionService

NAME

Constructor Summary

Constructors

Constructor and Description
HiveSessionService(org.apache.hive.service.cli.CLIService cliService) Instantiates a new hive session service.

Method Summary

Methods

Modifier and Type	Method and Description
void	addResource(LensSessionHandle sessionid, String type, String path) Adds the resource.
int	addResourceToAllServices(LensSessionHandle sessionid, String type, String path) Adds the resource to all services.
void	closeSession(LensSessionHandle sessionHandle) Close session.
void	deleteResource(LensSessionHandle sessionid, String type, String path) Delete resource.
List<String>	getAllSessionParameters(LensSessionHandle sessionid, boolean verbose, String key) Gets the all session parameters.
HealthStatus	getHealthStatus() Returns the health status of the service.
void	init(org.apache.hadoop.hive.conf.HiveConf hiveConf)
boolean	isOpen(LensSessionHandle sessionHandle) Returns true if the session is open
List<String>	listAllResources(LensSessionHandle sessionHandle, String type) Lists resources from the session service
LensSessionHandle	openSession(String username, String password, String database, Map<String,String> configuration) Open session.
void	readExternal(ObjectInput in)
void	setSessionParameter(LensSessionHandle sessionid, String key, String value) Sets the session parameter.
void	start()
void	stop()
void	writeExternal(ObjectOutput out)

Methods inherited from class org.apache.lens.server.BaseLensService

acquire, acquire, getCliService, getHiveSessionHandle, getLensConf, getLensConf, getNumberOfSessions, getServerDomain, getSession, getSessionManager, getValidPath, openSession, prepareStopping, release, release, removePrefixBeforeURI, restoreSession

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

getServices

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

getHiveConf, getName, getServiceState, getStartTime, register, unregister

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.lens.server.api.session.SessionService

restoreSession

Constructor Detail

HiveSessionService

public HiveSessionService(org.apache.hive.service.cli.CLIService cliService)

Instantiates a new hive session service.

Parameters:

cliService - the cli service

Method Detail

addResourceToAllServices

public int addResourceToAllServices(LensSessionHandle sessionid,
                           String type,
                           String path)

Adds the resource to all services.

Specified by:

addResourceToAllServices in interface SessionService

Parameters:

sessionid - the sessionid

type - the type

path - the path

Returns:

the number of services that the resource has been added to

listAllResources

public List<String> listAllResources(LensSessionHandle sessionHandle,
                            String type)

Description copied from interface: SessionService

Lists resources from the session service

Specified by:

listAllResources in interface SessionService

Parameters:

sessionHandle - the sessionid

type - the resource type, can be null, file or jar

Returns:

Lists resources for a given resource type. Lists all resources if resource type is null

addResource

public void addResource(LensSessionHandle sessionid,
               String type,
               String path)

Adds the resource.

Specified by:

addResource in interface SessionService

Overrides:

addResource in class BaseLensService

Parameters:

sessionid - the session handle

type - the type

path - the path

deleteResource

public void deleteResource(LensSessionHandle sessionid,
                  String type,
                  String path)

Delete resource.

Specified by:

deleteResource in interface SessionService

Overrides:

deleteResource in class BaseLensService

Parameters:

sessionid - the session handle

type - the type

path - the path

openSession

public LensSessionHandle openSession(String username,
                            String password,
                            String database,
                            Map<String,String> configuration)
                              throws LensException

Open session.

Specified by:

openSession in interface SessionService

Parameters:

username - the username

password - the password

database - Set current database to the supplied value

configuration - the configuration

Returns:

the lens session handle

Throws:

LensException - the lens exception

isOpen

public boolean isOpen(LensSessionHandle sessionHandle)

Description copied from interface: SessionService

Returns true if the session is open

Specified by:

isOpen in interface SessionService

getAllSessionParameters

public List<String> getAllSessionParameters(LensSessionHandle sessionid,
                                   boolean verbose,
                                   String key)
                                     throws LensException

Gets the all session parameters.

Specified by:

getAllSessionParameters in interface SessionService

Parameters:

sessionid - the sessionid

verbose - the verbose

key - the key

Returns:

the all session parameters

Throws:

LensException - the lens exception

setSessionParameter

public void setSessionParameter(LensSessionHandle sessionid,
                       String key,
                       String value)

Sets the session parameter.

Specified by:

setSessionParameter in interface SessionService

Parameters:

sessionid - the sessionid

key - the key

value - the value

init

public void init(org.apache.hadoop.hive.conf.HiveConf hiveConf)

Specified by:

init in interface org.apache.hive.service.Service

Overrides:

init in class org.apache.hive.service.CompositeService

start

public void start()

Specified by:

start in interface org.apache.hive.service.Service

Overrides:

start in class org.apache.hive.service.CompositeService

stop

public void stop()

Specified by:

stop in interface org.apache.hive.service.Service

Overrides:

stop in class org.apache.hive.service.CompositeService

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class BaseLensService

Throws:

IOException

getHealthStatus

public HealthStatus getHealthStatus()

Description copied from class: BaseLensService

Returns the health status of the service.

Specified by:

getHealthStatus in interface HealthCheckable

Specified by:

getHealthStatus in class BaseLensService

Returns:

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class BaseLensService

Throws:

IOException

ClassNotFoundException

closeSession

public void closeSession(LensSessionHandle sessionHandle)
                  throws LensException

Close session.

Specified by:

closeSession in interface SessionService

Overrides:

closeSession in class BaseLensService

Parameters:

sessionHandle - the session handle

Throws:

LensException - the lens exception