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.

Method Summary

void	close(TezSessionState tezSessionState)
static TezSessionPoolManager	getInstance()
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

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

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)
           throws Exception

Throws:

Exception

stop

public void stop()
          throws Exception

Throws:

Exception

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