Package org.apache.hadoop.mapreduce.v2.app

Class MRAppMaster.RunningAppContext

java.lang.Object

org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext

All Implemented Interfaces:

AppContext

Enclosing class:

MRAppMaster

public class MRAppMaster.RunningAppContext
extends Object
implements AppContext

Constructor Summary

Constructors

Constructor	Description
RunningAppContext(org.apache.hadoop.conf.Configuration config, TaskAttemptFinishingMonitor taskAttemptFinishingMonitor)

Method Summary

Modifier and Type	Method	Description
Map<org.apache.hadoop.mapreduce.v2.api.records.JobId,Job>	getAllJobs()
org.apache.hadoop.yarn.api.records.ApplicationAttemptId	getApplicationAttemptId()
org.apache.hadoop.yarn.api.records.ApplicationId	getApplicationID()
String	getApplicationName()
Set<String>	getBlacklistedNodes()
org.apache.hadoop.yarn.security.client.ClientToAMTokenSecretManager	getClientToAMTokenSecretManager()
org.apache.hadoop.yarn.util.Clock	getClock()
ClusterInfo	getClusterInfo()
org.apache.hadoop.yarn.event.EventHandler<org.apache.hadoop.yarn.event.Event>	getEventHandler()
String	getHistoryUrl()
Job	getJob(org.apache.hadoop.mapreduce.v2.api.records.JobId jobID)
String	getNMHostname()
long	getStartTime()
TaskAttemptFinishingMonitor	getTaskAttemptFinishingMonitor()
org.apache.hadoop.yarn.client.api.TimelineClient	getTimelineClient()
org.apache.hadoop.yarn.client.api.TimelineV2Client	getTimelineV2Client()
CharSequence	getUser()
boolean	hasSuccessfullyUnregistered()
boolean	isLastAMRetry()
void	markSuccessfulUnregistration()
void	resetIsLastAMRetry()
void	setHistoryUrl(String historyUrl)

Methods inherited from class java.lang.Object

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

Constructor Details

RunningAppContext

public RunningAppContext(org.apache.hadoop.conf.Configuration config,
 TaskAttemptFinishingMonitor taskAttemptFinishingMonitor)

Method Details

getApplicationAttemptId

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

Specified by:

getApplicationAttemptId in interface AppContext

getApplicationID

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

Specified by:

getApplicationID in interface AppContext

getApplicationName

public String getApplicationName()

Specified by:

getApplicationName in interface AppContext

getStartTime

public long getStartTime()

Specified by:

getStartTime in interface AppContext

getJob

public Job getJob(org.apache.hadoop.mapreduce.v2.api.records.JobId jobID)

Specified by:

getJob in interface AppContext

getAllJobs

public Map<org.apache.hadoop.mapreduce.v2.api.records.JobId,Job> getAllJobs()

Specified by:

getAllJobs in interface AppContext

getEventHandler

public org.apache.hadoop.yarn.event.EventHandler<org.apache.hadoop.yarn.event.Event> getEventHandler()

Specified by:

getEventHandler in interface AppContext

getUser

public CharSequence getUser()

Specified by:

getUser in interface AppContext

getClock

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

Specified by:

getClock in interface AppContext

getClusterInfo

public ClusterInfo getClusterInfo()

Specified by:

getClusterInfo in interface AppContext

getBlacklistedNodes

public Set<String> getBlacklistedNodes()

Specified by:

getBlacklistedNodes in interface AppContext

getClientToAMTokenSecretManager

public org.apache.hadoop.yarn.security.client.ClientToAMTokenSecretManager getClientToAMTokenSecretManager()

Specified by:

getClientToAMTokenSecretManager in interface AppContext

isLastAMRetry

public boolean isLastAMRetry()

Specified by:

isLastAMRetry in interface AppContext

hasSuccessfullyUnregistered

public boolean hasSuccessfullyUnregistered()

Specified by:

hasSuccessfullyUnregistered in interface AppContext

markSuccessfulUnregistration

public void markSuccessfulUnregistration()

resetIsLastAMRetry

public void resetIsLastAMRetry()

getNMHostname

public String getNMHostname()

Specified by:

getNMHostname in interface AppContext

getTaskAttemptFinishingMonitor

public TaskAttemptFinishingMonitor getTaskAttemptFinishingMonitor()

Specified by:

getTaskAttemptFinishingMonitor in interface AppContext

getTimelineClient

public org.apache.hadoop.yarn.client.api.TimelineClient getTimelineClient()

getTimelineV2Client

public org.apache.hadoop.yarn.client.api.TimelineV2Client getTimelineV2Client()

getHistoryUrl

public String getHistoryUrl()

Specified by:

getHistoryUrl in interface AppContext

setHistoryUrl

public void setHistoryUrl(String historyUrl)

Specified by:

setHistoryUrl in interface AppContext