public class TezSessionState extends Object
Modifier and Type | Field and Description |
---|---|
static String |
LLAP_SERVICE |
Constructor and Description |
---|
TezSessionState(DagUtils utils)
Constructor.
|
TezSessionState(String sessionId)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
beginOpen(HiveConf conf,
String[] additionalFiles,
SessionState.LogHelper console) |
void |
cleanupScratchDir() |
void |
close(boolean keepTmpDir)
Close a tez session.
|
void |
endOpen() |
Set<String> |
getAdditionalFilesNotFromConf() |
org.apache.hadoop.yarn.api.records.LocalResource |
getAppJarLr() |
HiveConf |
getConf() |
boolean |
getDoAsEnabled() |
List<org.apache.hadoop.yarn.api.records.LocalResource> |
getLocalizedResources() |
String |
getQueueName() |
org.apache.tez.client.TezClient |
getSession() |
String |
getSessionId() |
org.apache.hadoop.fs.Path |
getTezScratchDir() |
String |
getUser() |
boolean |
hasResources(String[] localAmResources) |
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(HiveConf conf) |
void |
open(HiveConf conf,
Collection<String> additionalFiles,
org.apache.hadoop.fs.Path scratchDir) |
void |
open(HiveConf conf,
String[] additionalFiles)
Creates a tez session.
|
protected void |
openInternal(HiveConf conf,
Collection<String> additionalFiles,
boolean isAsync,
SessionState.LogHelper console,
org.apache.hadoop.fs.Path scratchDir) |
void |
refreshLocalResourcesFromConf(HiveConf conf) |
void |
setDefault() |
void |
setQueueName(String queueName) |
String |
toString() |
public static final String LLAP_SERVICE
public TezSessionState(DagUtils utils)
public TezSessionState(String sessionId)
public boolean isOpening()
public boolean isOpen()
public static String makeSessionId()
public void open(HiveConf conf) throws IOException, LoginException, URISyntaxException, org.apache.tez.dag.api.TezException
IOException
LoginException
URISyntaxException
org.apache.tez.dag.api.TezException
public void open(HiveConf conf, String[] additionalFiles) throws IOException, LoginException, IllegalArgumentException, URISyntaxException, org.apache.tez.dag.api.TezException
IOException
URISyntaxException
LoginException
org.apache.tez.dag.api.TezException
InterruptedException
IllegalArgumentException
public void beginOpen(HiveConf conf, String[] additionalFiles, SessionState.LogHelper console) throws IOException, LoginException, IllegalArgumentException, URISyntaxException, org.apache.tez.dag.api.TezException
IOException
LoginException
IllegalArgumentException
URISyntaxException
org.apache.tez.dag.api.TezException
public void open(HiveConf conf, Collection<String> additionalFiles, org.apache.hadoop.fs.Path scratchDir) throws LoginException, IOException, URISyntaxException, org.apache.tez.dag.api.TezException
LoginException
IOException
URISyntaxException
org.apache.tez.dag.api.TezException
protected void openInternal(HiveConf conf, Collection<String> additionalFiles, boolean isAsync, SessionState.LogHelper console, org.apache.hadoop.fs.Path scratchDir) throws IOException, LoginException, IllegalArgumentException, URISyntaxException, org.apache.tez.dag.api.TezException
IOException
LoginException
IllegalArgumentException
URISyntaxException
org.apache.tez.dag.api.TezException
public void endOpen() throws InterruptedException, CancellationException
public void refreshLocalResourcesFromConf(HiveConf conf) throws IOException, LoginException, IllegalArgumentException, URISyntaxException, org.apache.tez.dag.api.TezException
IOException
LoginException
IllegalArgumentException
URISyntaxException
org.apache.tez.dag.api.TezException
public boolean hasResources(String[] localAmResources)
public void close(boolean keepTmpDir) throws Exception
keepTmpDir
- whether or not to remove the scratch dir at the same time.Exception
public void cleanupScratchDir() throws IOException
IOException
public String getSessionId()
public org.apache.tez.client.TezClient getSession()
public org.apache.hadoop.fs.Path getTezScratchDir()
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()
Copyright © 2016 The Apache Software Foundation. All rights reserved.