public class TezSessionState extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TezSessionState.HiveResources |
Modifier and Type | Field and Description |
---|---|
static String |
LLAP_SERVICE |
protected static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
TezSessionState(DagUtils utils,
HiveConf conf)
Constructor.
|
TezSessionState(String sessionId,
HiveConf conf)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
beginOpen(String[] additionalFiles,
SessionState.LogHelper console) |
protected void |
cleanupDagResources() |
protected void |
cleanupScratchDir() |
void |
destroy() |
void |
endOpen() |
void |
ensureLocalResources(org.apache.hadoop.conf.Configuration conf,
String[] newFilesNotFromConf)
This is called in openInternal and in TezTask.updateSession to localize conf resources.
|
TezSessionState.HiveResources |
extractHiveResources() |
org.apache.hadoop.yarn.api.records.LocalResource |
getAppJarLr() |
HiveConf |
getConf() |
boolean |
getDoAsEnabled() |
KillQuery |
getKillQuery() |
List<org.apache.hadoop.yarn.api.records.LocalResource> |
getLocalizedResources() |
String |
getQueueName() |
org.apache.tez.client.TezClient |
getSession() |
String |
getSessionId() |
String |
getUser() |
WmContext |
getWmContext() |
boolean |
isDefault() |
boolean |
isOpen() |
boolean |
isOpening() |
static String |
makeSessionId()
Get all open sessions.
|
void |
markFree()
Mark session as free for use from TezTask, for safety/debugging purposes.
|
void |
markInUse()
Mark session as being in use from TezTask, for safety/debugging purposes.
|
void |
open() |
void |
open(String[] additionalFilesNotFromConf)
Creates a tez session.
|
void |
open(TezSessionState.HiveResources resources) |
protected void |
openInternal(String[] additionalFilesNotFromConf,
boolean isAsync,
SessionState.LogHelper console,
TezSessionState.HiveResources resources) |
TezSessionState |
reopen() |
org.apache.hadoop.fs.Path |
replaceHiveResources(TezSessionState.HiveResources resources,
boolean isAsync) |
void |
returnToSessionManager() |
void |
setDefault() |
void |
setKillQuery(KillQuery killQuery) |
void |
setQueueName(String queueName) |
void |
setWmContext(WmContext wmContext) |
String |
toString() |
protected static final org.slf4j.Logger LOG
public static final String LLAP_SERVICE
public TezSessionState(DagUtils utils, HiveConf conf)
public boolean isOpening()
public boolean isOpen()
public static String makeSessionId()
public void open() throws IOException, LoginException, URISyntaxException, org.apache.tez.dag.api.TezException
IOException
LoginException
URISyntaxException
org.apache.tez.dag.api.TezException
public void open(String[] additionalFilesNotFromConf) throws IOException, LoginException, URISyntaxException, org.apache.tez.dag.api.TezException
IOException
LoginException
URISyntaxException
org.apache.tez.dag.api.TezException
public void open(TezSessionState.HiveResources resources) throws LoginException, IOException, URISyntaxException, org.apache.tez.dag.api.TezException
LoginException
IOException
URISyntaxException
org.apache.tez.dag.api.TezException
public void beginOpen(String[] additionalFiles, SessionState.LogHelper console) throws IOException, LoginException, URISyntaxException, org.apache.tez.dag.api.TezException
IOException
LoginException
URISyntaxException
org.apache.tez.dag.api.TezException
protected void openInternal(String[] additionalFilesNotFromConf, boolean isAsync, SessionState.LogHelper console, TezSessionState.HiveResources resources) throws IOException, LoginException, URISyntaxException, org.apache.tez.dag.api.TezException
IOException
LoginException
URISyntaxException
org.apache.tez.dag.api.TezException
public void endOpen() throws InterruptedException, CancellationException
public void ensureLocalResources(org.apache.hadoop.conf.Configuration conf, String[] newFilesNotFromConf) throws IOException, LoginException, URISyntaxException, org.apache.tez.dag.api.TezException
IOException
LoginException
URISyntaxException
org.apache.tez.dag.api.TezException
protected final void cleanupScratchDir() throws IOException
IOException
protected final void cleanupDagResources() throws IOException
IOException
public String getSessionId()
public org.apache.tez.client.TezClient getSession()
public org.apache.hadoop.yarn.api.records.LocalResource getAppJarLr()
public void setQueueName(String queueName)
public String getQueueName()
public void setDefault()
public boolean isDefault()
public HiveConf getConf()
public List<org.apache.hadoop.yarn.api.records.LocalResource> getLocalizedResources()
public String getUser()
public boolean getDoAsEnabled()
public void markFree()
public void markInUse()
public TezSessionState reopen() throws Exception
Exception
public WmContext getWmContext()
public void setWmContext(WmContext wmContext)
public void setKillQuery(KillQuery killQuery)
public KillQuery getKillQuery()
public TezSessionState.HiveResources extractHiveResources()
public org.apache.hadoop.fs.Path replaceHiveResources(TezSessionState.HiveResources resources, boolean isAsync)
Copyright © 2022 The Apache Software Foundation. All rights reserved.