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

Class TezSessionState

java.lang.Object

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

public class TezSessionState
extends Object

Holds session state related to Tez

Constructor Summary

Constructors

Constructor and Description
TezSessionState(DagUtils utils) Constructor.
TezSessionState(String sessionId) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanupScratchDir()
void	close(boolean keepTmpDir) Close a tez session.
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() Returns whether a session has been established
static String	makeSessionId() Get all open sessions.
void	open(HiveConf conf)
void	open(HiveConf conf, String[] additionalFiles) Creates a tez session.
void	refreshLocalResourcesFromConf(HiveConf conf)
void	setDefault()
void	setQueueName(String queueName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TezSessionState

public TezSessionState(DagUtils utils)

Constructor. We do not automatically connect, because we only want to load tez classes when the user has tez installed.

TezSessionState

public TezSessionState(String sessionId)

Constructor. We do not automatically connect, because we only want to load tez classes when the user has tez installed.

Method Detail

isOpen

public boolean isOpen()

Returns whether a session has been established

makeSessionId

public static String makeSessionId()

Get all open sessions. Only used to clean up at shutdown.

Returns:

List

open

public void open(HiveConf conf)
          throws IOException,
                 LoginException,
                 URISyntaxException,
                 org.apache.tez.dag.api.TezException

Throws:

IOException

LoginException

URISyntaxException

org.apache.tez.dag.api.TezException

open

public void open(HiveConf conf,
        String[] additionalFiles)
          throws IOException,
                 LoginException,
                 IllegalArgumentException,
                 URISyntaxException,
                 org.apache.tez.dag.api.TezException

Creates a tez session. A session is tied to either a cli/hs2 session. You can submit multiple DAGs against a session (as long as they are executed serially).

Throws:

IOException

URISyntaxException

LoginException

org.apache.tez.dag.api.TezException

IllegalArgumentException

refreshLocalResourcesFromConf

public void refreshLocalResourcesFromConf(HiveConf conf)
                                   throws IOException,
                                          LoginException,
                                          IllegalArgumentException,
                                          URISyntaxException,
                                          org.apache.tez.dag.api.TezException

Throws:

IOException

LoginException

IllegalArgumentException

URISyntaxException

org.apache.tez.dag.api.TezException

hasResources

public boolean hasResources(String[] localAmResources)

close

public void close(boolean keepTmpDir)
           throws org.apache.tez.dag.api.TezException,
                  IOException

Close a tez session. Will cleanup any tez/am related resources. After closing a session no further DAGs can be executed against it.

Parameters:

keepTmpDir - whether or not to remove the scratch dir at the same time.

Throws:

IOException

org.apache.tez.dag.api.TezException

cleanupScratchDir

public void cleanupScratchDir()
                       throws IOException

Throws:

IOException

getSessionId

public String getSessionId()

getSession

public org.apache.tez.client.TezClient getSession()

getTezScratchDir

public org.apache.hadoop.fs.Path getTezScratchDir()

getAppJarLr

public org.apache.hadoop.yarn.api.records.LocalResource getAppJarLr()

setQueueName

public void setQueueName(String queueName)

getQueueName

public String getQueueName()

setDefault

public void setDefault()

isDefault

public boolean isDefault()

getConf

public HiveConf getConf()

getLocalizedResources

public List<org.apache.hadoop.yarn.api.records.LocalResource> getLocalizedResources()

getUser

public String getUser()

getDoAsEnabled

public boolean getDoAsEnabled()