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

Class WmTezSession

java.lang.Object

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

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

All Implemented Interfaces:

AmPluginNode

public class WmTezSession
extends TezSessionState
implements AmPluginNode

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TezSessionPoolSession.AbstractTriggerValidator
static interface	TezSessionPoolSession.Manager

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.exec.tez.TezSessionState

TezSessionState.HiveResources

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.ql.exec.tez.AmPluginNode

AmPluginNode.AmPluginInfo

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.exec.tez.TezSessionState

LLAP_SERVICE, LOG

Constructor Summary

Constructors

Constructor and Description
WmTezSession(String sessionId, WorkloadManager parent, org.apache.hadoop.hive.ql.exec.tez.SessionExpirationTracker expiration, HiveConf conf)

Method Summary

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)

Methods inherited from class org.apache.hadoop.hive.ql.exec.tez.TezSessionState

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

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

WmTezSession

public WmTezSession(String sessionId,
                    WorkloadManager parent,
                    org.apache.hadoop.hive.ql.exec.tez.SessionExpirationTracker expiration,
                    HiveConf conf)

Method Detail

waitForAmRegistryAsync

public com.google.common.util.concurrent.ListenableFuture<WmTezSession> waitForAmRegistryAsync(int timeoutMs,
                                                                                               ScheduledExecutorService timeoutPool)

updateAmEndpointInfo

public void updateAmEndpointInfo(TezAmInstance si,
                                 int ephSeqVersion)

getAmPluginInfo

public AmPluginNode.AmPluginInfo getAmPluginInfo(Ref<Integer> version)

Specified by:

getAmPluginInfo in interface AmPluginNode

getPoolName

public String getPoolName()

hasClusterFraction

public boolean hasClusterFraction()

getClusterFraction

public double getClusterFraction()

getAllocationState

public String getAllocationState()

handleUpdateError

public void handleUpdateError(int endpointVersion)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

setQueryId

public void setQueryId(String queryId)

getQueryId

public String getQueryId()

toString

public String toString()

openInternal

protected void openInternal(String[] additionalFiles,
                            boolean isAsync,
                            SessionState.LogHelper console,
                            TezSessionState.HiveResources resources)
                     throws IOException,
                            LoginException,
                            URISyntaxException,
                            org.apache.tez.dag.api.TezException

Overrides:

openInternal in class TezSessionState

Throws:

IOException

LoginException

URISyntaxException

org.apache.tez.dag.api.TezException

tryUse

public boolean tryUse(boolean ignoreExpiration)

Tries to use this session. When the session is in use, it will not expire.

Returns:

true if the session can be used; false if it has already expired.

tryExpire

public boolean tryExpire(boolean isAsync)
                  throws Exception

Tries to expire and restart the session.

Parameters:

isAsync - Whether the restart should happen asynchronously.

Returns:

True if the session was, or will be restarted.

Throws:

Exception

returnToSessionManager

public void returnToSessionManager()
                            throws Exception

Overrides:

returnToSessionManager in class TezSessionState

Throws:

Exception

reopen

public TezSessionState reopen()
                       throws Exception

Overrides:

reopen in class TezSessionState

Throws:

Exception

destroy

public void destroy()
             throws Exception

Overrides:

destroy in class TezSessionState

Throws:

Exception