org.apache.lens.server.session

Class LensSessionImpl

java.lang.Object

org.apache.hive.service.cli.session.HiveSessionImpl

org.apache.lens.server.session.LensSessionImpl

All Implemented Interfaces:

AutoCloseable, org.apache.hive.service.cli.session.HiveSession, org.apache.hive.service.cli.session.HiveSessionBase

public class LensSessionImpl
extends org.apache.hive.service.cli.session.HiveSessionImpl
implements AutoCloseable

The Class LensSessionImpl.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LensSessionImpl.LensSessionPersistInfo The Class LensSessionPersistInfo.
static class	LensSessionImpl.ResourceEntry The Class ResourceEntry.

Field Summary

Fields

Modifier and Type	Field and Description
static Map<String,String>	DEFAULT_HIVE_SESSION_CONF The default hive session conf.

Constructor Summary

Constructors

Constructor and Description
LensSessionImpl(org.apache.hive.service.cli.SessionHandle sessionHandle, org.apache.hive.service.rpc.thrift.TProtocolVersion protocol, String username, String password, org.apache.hadoop.hive.conf.HiveConf serverConf, String ipAddress) Constructor used when restoring session.
LensSessionImpl(org.apache.hive.service.rpc.thrift.TProtocolVersion protocol, String username, String password, org.apache.hadoop.hive.conf.HiveConf serverConf, String ipAddress) Instantiates a new lens session impl.

Method Summary

Methods

Modifier and Type	Method and Description
void	acquire()
void	acquire(boolean userAccess)
boolean	activeOperationsPresent()
void	addResource(String type, String path, String finalLocation) Adds the resource.
void	addToActiveQueries(QueryHandle queryHandle)
void	close()
static org.apache.hadoop.conf.Configuration	createDefaultConf() Creates the default conf.
List<QueryHandle>	getActiveQueries() List of queries which are submitted in this session.
ClassLoader	getClassLoader()
String	getClusterUser()
CubeMetastoreClient	getCubeMetastoreClient()
String	getCurrentDatabase()
Collection<LensSessionImpl.ResourceEntry>	getDBResources(String database) Return resources which are added statically to the database
static Map<String,String>	getHiveSessionConf()
long	getLastAccessTime()
LensSessionImpl.LensSessionPersistInfo	getLensSessionPersistInfo()
String	getLoggedInUser()
Collection<LensSessionImpl.ResourceEntry>	getPendingSessionResourcesForDatabase(String database) Get session's resources which have to be added for the given database
org.apache.hadoop.conf.Configuration	getSessionConf()
boolean	isActive()
void	markForClose()
void	open(Map<String,String> sessionConfMap)
void	release()
void	release(boolean userAccess)
void	removeFromActiveQueries(QueryHandle queryHandle)
void	removeResource(String type, String path) Removes the resource.
void	setActive()
void	setConfig(Map<String,String> config) Sets the config.
void	setCurrentDatabase(String currentDatabase)
String	toString()

Methods inherited from class org.apache.hive.service.cli.session.HiveSessionImpl

cancelDelegationToken, cancelOperation, closeExpiredOperations, closeOperation, executeStatement, executeStatement, executeStatementAsync, executeStatementAsync, fetchResults, getCatalogs, getColumns, getCreationTime, getCrossReference, getDelegationToken, getFunctions, getHiveConf, getInfo, getIpAddress, getMetaStoreClient, getNoOperationTime, getOpenOperationCount, getOperationLogSessionDir, getPassword, getPrimaryKeys, getProtocolVersion, getResultSetMetadata, getSchemas, getSessionHandle, getSessionHive, getSessionManager, getSessionState, getTables, getTableTypes, getTypeInfo, getUserName, isOperationLogEnabled, renewDelegationToken, setIpAddress, setOperationLogSessionDir, setOperationManager, setSessionManager, setUserName

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_HIVE_SESSION_CONF

public static final Map<String,String> DEFAULT_HIVE_SESSION_CONF

The default hive session conf.

Constructor Detail

LensSessionImpl

public LensSessionImpl(org.apache.hive.service.rpc.thrift.TProtocolVersion protocol,
               String username,
               String password,
               org.apache.hadoop.hive.conf.HiveConf serverConf,
               String ipAddress)

Instantiates a new lens session impl.

Parameters:

protocol - the protocol

username - the username

password - the password

serverConf - the server conf

ipAddress - the ip address

LensSessionImpl

public LensSessionImpl(org.apache.hive.service.cli.SessionHandle sessionHandle,
               org.apache.hive.service.rpc.thrift.TProtocolVersion protocol,
               String username,
               String password,
               org.apache.hadoop.hive.conf.HiveConf serverConf,
               String ipAddress)

Constructor used when restoring session.

Parameters:

sessionHandle - the session handle

protocol - the protocol

username - the username

password - the password

serverConf - the server conf

ipAddress - the ip address

Method Detail

createDefaultConf

public static org.apache.hadoop.conf.Configuration createDefaultConf()

Creates the default conf.

Returns:

the configuration

getHiveSessionConf

public static Map<String,String> getHiveSessionConf()

getSessionConf

public org.apache.hadoop.conf.Configuration getSessionConf()

open

public void open(Map<String,String> sessionConfMap)
          throws org.apache.hive.service.cli.HiveSQLException

Specified by:

open in interface org.apache.hive.service.cli.session.HiveSession

Overrides:

open in class org.apache.hive.service.cli.session.HiveSessionImpl

Throws:

org.apache.hive.service.cli.HiveSQLException

close

public void close()
           throws org.apache.hive.service.cli.HiveSQLException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hive.service.cli.session.HiveSession

Overrides:

close in class org.apache.hive.service.cli.session.HiveSessionImpl

Throws:

org.apache.hive.service.cli.HiveSQLException

getCubeMetastoreClient

public CubeMetastoreClient getCubeMetastoreClient()
                                           throws LensException

Throws:

LensException

acquire

public void acquire()

acquire

public void acquire(boolean userAccess)

Overrides:

acquire in class org.apache.hive.service.cli.session.HiveSessionImpl

release

public void release()

release

public void release(boolean userAccess)

Overrides:

release in class org.apache.hive.service.cli.session.HiveSessionImpl

isActive

public boolean isActive()

setActive

public void setActive()

setConfig

public void setConfig(Map<String,String> config)

Sets the config.

Parameters:

config - the config to overlay

removeResource

public void removeResource(String type,
                  String path)

Removes the resource.

Parameters:

type - the type

path - the path

addResource

public void addResource(String type,
               String path,
               String finalLocation)

Adds the resource.

Parameters:

type - the type

path - the path

finalLocation - The final location where resources is downloaded

setCurrentDatabase

public void setCurrentDatabase(String currentDatabase)

getCurrentDatabase

public String getCurrentDatabase()

toString

public String toString()

Overrides:

toString in class Object

getLoggedInUser

public String getLoggedInUser()

getClusterUser

public String getClusterUser()

getLensSessionPersistInfo

public LensSessionImpl.LensSessionPersistInfo getLensSessionPersistInfo()

getLastAccessTime

public long getLastAccessTime()

Specified by:

getLastAccessTime in interface org.apache.hive.service.cli.session.HiveSessionBase

Overrides:

getLastAccessTime in class org.apache.hive.service.cli.session.HiveSessionImpl

getDBResources

public Collection<LensSessionImpl.ResourceEntry> getDBResources(String database)

Return resources which are added statically to the database

Returns:

db resources

getPendingSessionResourcesForDatabase

public Collection<LensSessionImpl.ResourceEntry> getPendingSessionResourcesForDatabase(String database)

Get session's resources which have to be added for the given database

getClassLoader

public ClassLoader getClassLoader()

Returns:

effective class loader for this session

markForClose

public void markForClose()

addToActiveQueries

public void addToActiveQueries(QueryHandle queryHandle)

removeFromActiveQueries

public void removeFromActiveQueries(QueryHandle queryHandle)

activeOperationsPresent

public boolean activeOperationsPresent()

getActiveQueries

@Generated(value="lombok")
public List<QueryHandle> getActiveQueries()

List of queries which are submitted in this session.