org.apache.tez.dag.app

Interface AppContext

@InterfaceAudience.Private
public interface AppContext

Context interface for sharing information across components in Tez DAG

Method Summary

Methods

Modifier and Type	Method and Description
AMContainerMap	getAllContainers()
Set<String>	getAllDAGIDs()
org.apache.tez.common.security.ACLManager	getAMACLManager()
org.apache.hadoop.conf.Configuration	getAMConf()
DAGAppMasterState	getAMState()
String	getAMUser()
Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType,String>	getApplicationACLs()
org.apache.hadoop.yarn.api.records.ApplicationAttemptId	getApplicationAttemptId()
org.apache.hadoop.yarn.api.records.ApplicationId	getApplicationID()
String	getApplicationName()
DAGAppMaster	getAppMaster()
org.apache.hadoop.yarn.util.Clock	getClock()
ClusterInfo	getClusterInfo()
long	getCumulativeCPUTime()
long	getCumulativeGCTime()
DAG	getCurrentDAG()
org.apache.tez.dag.records.TezDAGID	getCurrentDAGID()
org.apache.hadoop.fs.Path	getCurrentRecoveryDir()
org.apache.hadoop.yarn.event.EventHandler	getEventHandler()
com.google.common.util.concurrent.ListeningExecutorService	getExecService()
HistoryEventHandler	getHistoryHandler()
String[]	getLocalDirs()
String[]	getLogDirs()
AMNodeTracker	getNodeTracker()
long	getStartTime()
TaskSchedulerEventHandler	getTaskScheduler()
String	getUser()
boolean	isRecoveryEnabled()
boolean	isSession()
void	setDAG(DAG dag)

Method Detail

getAppMaster

DAGAppMaster getAppMaster()

getAMConf

org.apache.hadoop.conf.Configuration getAMConf()

getApplicationID

org.apache.hadoop.yarn.api.records.ApplicationId getApplicationID()

getCurrentDAGID

org.apache.tez.dag.records.TezDAGID getCurrentDAGID()

getCumulativeCPUTime

long getCumulativeCPUTime()

getCumulativeGCTime

long getCumulativeGCTime()

getApplicationAttemptId

org.apache.hadoop.yarn.api.records.ApplicationAttemptId getApplicationAttemptId()

getApplicationName

String getApplicationName()

getApplicationACLs

Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType,String> getApplicationACLs()

getStartTime

long getStartTime()

getUser

String getUser()

getCurrentDAG

DAG getCurrentDAG()

getExecService

com.google.common.util.concurrent.ListeningExecutorService getExecService()

setDAG

void setDAG(DAG dag)

getAllDAGIDs

Set<String> getAllDAGIDs()

getEventHandler

org.apache.hadoop.yarn.event.EventHandler getEventHandler()

getClock

org.apache.hadoop.yarn.util.Clock getClock()

getClusterInfo

ClusterInfo getClusterInfo()

getAllContainers

AMContainerMap getAllContainers()

getNodeTracker

AMNodeTracker getNodeTracker()

getTaskScheduler

TaskSchedulerEventHandler getTaskScheduler()

isSession

boolean isSession()

getAMState

DAGAppMasterState getAMState()

getHistoryHandler

HistoryEventHandler getHistoryHandler()

getCurrentRecoveryDir

org.apache.hadoop.fs.Path getCurrentRecoveryDir()

isRecoveryEnabled

boolean isRecoveryEnabled()

getAMACLManager

org.apache.tez.common.security.ACLManager getAMACLManager()

getLogDirs

String[] getLogDirs()

getLocalDirs

String[] getLocalDirs()

getAMUser

String getAMUser()