public class TezSessionPoolManager extends Object
Modifier | Constructor and Description |
---|---|
protected |
TezSessionPoolManager() |
Modifier and Type | Method and Description |
---|---|
static void |
closeIfNotDefault(TezSessionState tezSessionState,
boolean keepTmpDir) |
void |
closeNonDefaultSessions(boolean keepTmpDir) |
protected org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager.TezSessionPoolSession |
createSession(String sessionId) |
void |
destroySession(TezSessionState tezSessionState)
This is called only in extreme cases where even our retry of submit fails.
|
static TezSessionPoolManager |
getInstance() |
TezSessionState |
getSession(TezSessionState session,
HiveConf conf,
boolean doOpen,
boolean llap) |
void |
reopenSession(TezSessionState sessionState,
HiveConf conf,
String[] additionalFiles,
boolean keepTmpDir)
Reopens the session that was found to not be running.
|
void |
returnSession(TezSessionState tezSessionState,
boolean llap) |
void |
setupPool(HiveConf conf) |
void |
startPool() |
void |
stop() |
public static TezSessionPoolManager getInstance() throws Exception
Exception
public void setupPool(HiveConf conf) throws InterruptedException
InterruptedException
public void returnSession(TezSessionState tezSessionState, boolean llap) throws Exception
Exception
public static void closeIfNotDefault(TezSessionState tezSessionState, boolean keepTmpDir) throws Exception
Exception
public void destroySession(TezSessionState tezSessionState) throws Exception
tezSessionState
- the session to be closedException
protected org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager.TezSessionPoolSession createSession(String sessionId)
public TezSessionState getSession(TezSessionState session, HiveConf conf, boolean doOpen, boolean llap) throws Exception
Exception
public void reopenSession(TezSessionState sessionState, HiveConf conf, String[] additionalFiles, boolean keepTmpDir) throws Exception
Exception
Copyright © 2017 The Apache Software Foundation. All rights reserved.