public class WmTezSession extends TezSessionState implements AmPluginNode
Modifier and Type | Class and Description |
---|---|
static class |
TezSessionPoolSession.AbstractTriggerValidator |
static interface |
TezSessionPoolSession.Manager |
TezSessionState.HiveResources
AmPluginNode.AmPluginInfo
LLAP_SERVICE, LOG
Constructor and Description |
---|
WmTezSession(String sessionId,
WorkloadManager parent,
org.apache.hadoop.hive.ql.exec.tez.SessionExpirationTracker expiration,
HiveConf conf) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
boolean |
equals(Object obj) |
String |
getAllocationState() |
AmPluginNode.AmPluginInfo |
getAmPluginInfo(Ref<Integer> version) |
double |
getClusterFraction() |
String |
getPoolName() |
String |
getQueryId() |
void |
handleUpdateError(int endpointVersion) |
boolean |
hasClusterFraction() |
int |
hashCode() |
protected void |
openInternal(String[] additionalFiles,
boolean isAsync,
SessionState.LogHelper console,
TezSessionState.HiveResources resources) |
TezSessionState |
reopen() |
void |
returnToSessionManager() |
void |
setQueryId(String queryId) |
String |
toString() |
boolean |
tryExpire(boolean isAsync)
Tries to expire and restart the session.
|
boolean |
tryUse(boolean ignoreExpiration)
Tries to use this session.
|
void |
updateAmEndpointInfo(TezAmInstance si,
int ephSeqVersion) |
com.google.common.util.concurrent.ListenableFuture<WmTezSession> |
waitForAmRegistryAsync(int timeoutMs,
ScheduledExecutorService timeoutPool) |
beginOpen, cleanupDagResources, cleanupScratchDir, endOpen, ensureLocalResources, extractHiveResources, getAppJarLr, getConf, getDoAsEnabled, getKillQuery, getLocalizedResources, getQueueName, getSession, getSessionId, getUser, getWmContext, isDefault, isOpen, isOpening, makeSessionId, markFree, markInUse, open, open, open, replaceHiveResources, setDefault, setKillQuery, setQueueName, setWmContext
public WmTezSession(String sessionId, WorkloadManager parent, org.apache.hadoop.hive.ql.exec.tez.SessionExpirationTracker expiration, HiveConf conf)
public com.google.common.util.concurrent.ListenableFuture<WmTezSession> waitForAmRegistryAsync(int timeoutMs, ScheduledExecutorService timeoutPool)
public void updateAmEndpointInfo(TezAmInstance si, int ephSeqVersion)
public AmPluginNode.AmPluginInfo getAmPluginInfo(Ref<Integer> version)
getAmPluginInfo
in interface AmPluginNode
public String getPoolName()
public boolean hasClusterFraction()
public double getClusterFraction()
public String getAllocationState()
public void handleUpdateError(int endpointVersion)
public void setQueryId(String queryId)
public String getQueryId()
public String toString()
protected void openInternal(String[] additionalFiles, boolean isAsync, SessionState.LogHelper console, TezSessionState.HiveResources resources) throws IOException, LoginException, URISyntaxException, org.apache.tez.dag.api.TezException
openInternal
in class TezSessionState
IOException
LoginException
URISyntaxException
org.apache.tez.dag.api.TezException
public boolean tryUse(boolean ignoreExpiration)
public boolean tryExpire(boolean isAsync) throws Exception
isAsync
- Whether the restart should happen asynchronously.Exception
public void returnToSessionManager() throws Exception
returnToSessionManager
in class TezSessionState
Exception
public TezSessionState reopen() throws Exception
reopen
in class TezSessionState
Exception
public void destroy() throws Exception
destroy
in class TezSessionState
Exception
Copyright © 2022 The Apache Software Foundation. All rights reserved.