org.apache.hadoop.hive.ql.exec.tez

Class TezSessionPoolManager

java.lang.Object

org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager

public class TezSessionPoolManager
extends Object

This class is for managing multiple tez sessions particularly when HiveServer2 is being used to submit queries. In case the user specifies a queue explicitly, a new session is created on that queue and assigned to the session state.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TezSessionPoolManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	close(TezSessionState tezSessionState, boolean keepTmpDir)
void	closeAndOpen(TezSessionState sessionState, HiveConf conf, boolean keepTmpDir)
void	closeAndOpen(TezSessionState sessionState, HiveConf conf, String[] additionalFiles, boolean keepTmpDir)
protected TezSessionState	createSession(String sessionId)
static TezSessionPoolManager	getInstance()
List<TezSessionState>	getOpenSessions()
TezSessionState	getSession(TezSessionState session, HiveConf conf, boolean doOpen)
TezSessionState	getSession(TezSessionState session, HiveConf conf, boolean doOpen, boolean forceCreate)
void	returnSession(TezSessionState tezSessionState)
void	setupPool(HiveConf conf)
void	startPool()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

TezSessionPoolManager

protected TezSessionPoolManager()

Method Detail

getInstance

public static TezSessionPoolManager getInstance()
                                         throws Exception

Throws:

Exception

startPool

public void startPool()
               throws Exception

Throws:

Exception

setupPool

public void setupPool(HiveConf conf)
               throws InterruptedException

Throws:

InterruptedException

returnSession

public void returnSession(TezSessionState tezSessionState)
                   throws Exception

Throws:

Exception

close

public void close(TezSessionState tezSessionState,
         boolean keepTmpDir)
           throws Exception

Throws:

Exception

stop

public void stop()
          throws Exception

Throws:

Exception

createSession

protected TezSessionState createSession(String sessionId)

getSession

public TezSessionState getSession(TezSessionState session,
                         HiveConf conf,
                         boolean doOpen)
                           throws Exception

Throws:

Exception

getSession

public TezSessionState getSession(TezSessionState session,
                         HiveConf conf,
                         boolean doOpen,
                         boolean forceCreate)
                           throws Exception

Throws:

Exception

closeAndOpen

public void closeAndOpen(TezSessionState sessionState,
                HiveConf conf,
                boolean keepTmpDir)
                  throws Exception

Throws:

Exception

closeAndOpen

public void closeAndOpen(TezSessionState sessionState,
                HiveConf conf,
                String[] additionalFiles,
                boolean keepTmpDir)
                  throws Exception

Throws:

Exception

getOpenSessions

public List<TezSessionState> getOpenSessions()