public class TezSessionPoolManager extends TezSessionPoolSession.AbstractTriggerValidator implements TezSessionPoolSession.Manager
Modifier | Constructor and Description |
---|---|
protected |
TezSessionPoolManager() |
Modifier and Type | Method and Description |
---|---|
void |
closeAndReopenExpiredSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession oldSession)
Closes a running (expired) pool session and reopens it.
|
static void |
closeIfNotDefault(TezSessionState tezSessionState,
boolean keepTmpDir) |
void |
closeNonDefaultSessions() |
protected org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession |
createSession(String sessionId,
HiveConf conf) |
void |
destroy(TezSessionState tezSessionState)
This is called only in extreme cases where even our retry of submit fails.
|
org.apache.hadoop.hive.ql.exec.tez.SessionExpirationTracker |
getExpirationTracker() |
static TezSessionPoolManager |
getInstance()
Note: this is not thread-safe.
|
TezSessionState |
getSession(TezSessionState session,
HiveConf conf,
boolean doOpen,
boolean llap) |
void |
initTriggers(HiveConf conf) |
void |
registerOpenSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session)
Called by TezSessionPoolSession when opened.
|
TezSessionState |
reopen(TezSessionState sessionState)
Reopens the session that was found to not be running.
|
void |
returnAfterUse(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session) |
void |
setupNonPool(HiveConf conf) |
void |
setupPool(HiveConf conf) |
void |
startPool(HiveConf conf,
WMFullResourcePlan resourcePlan) |
void |
stop() |
void |
unregisterOpenSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session)
Called by TezSessionPoolSession when closed.
|
void |
updateTriggers(WMFullResourcePlan appliedRp) |
public static TezSessionPoolManager getInstance()
public void startPool(HiveConf conf, WMFullResourcePlan resourcePlan) throws Exception
Exception
public void setupNonPool(HiveConf conf)
public void initTriggers(HiveConf conf)
public void returnAfterUse(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session) throws Exception
returnAfterUse
in interface TezSessionPoolSession.Manager
Exception
public static void closeIfNotDefault(TezSessionState tezSessionState, boolean keepTmpDir) throws Exception
Exception
public void destroy(TezSessionState tezSessionState) throws Exception
destroy
in interface TezSessionPoolSession.Manager
tezSessionState
- the session to be closedException
protected org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession createSession(String sessionId, HiveConf conf)
public TezSessionState getSession(TezSessionState session, HiveConf conf, boolean doOpen, boolean llap) throws Exception
Exception
public TezSessionState reopen(TezSessionState sessionState) throws Exception
reopen
in interface TezSessionPoolSession.Manager
Exception
public void closeAndReopenExpiredSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession oldSession) throws Exception
Exception
public void registerOpenSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session)
registerOpenSession
in interface TezSessionPoolSession.Manager
public void updateTriggers(WMFullResourcePlan appliedRp)
public void unregisterOpenSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session)
unregisterOpenSession
in interface TezSessionPoolSession.Manager
public org.apache.hadoop.hive.ql.exec.tez.SessionExpirationTracker getExpirationTracker()
Copyright © 2022 The Apache Software Foundation. All rights reserved.