Package org.apache.hadoop.yarn.server.resourcemanager.recovery.records

Class ApplicationStateData

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.recovery.records.ApplicationStateData

Direct Known Subclasses:

ApplicationStateDataPBImpl

@Public
@Unstable
public abstract class ApplicationStateData
extends Object

Contains all the state data that needs to be stored persistently for an Application

Field Summary

Fields

Modifier and Type	Field	Description
Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,ApplicationAttemptStateData>	attempts

Constructor Summary

Constructors

Constructor	Description
ApplicationStateData()

Method Summary

Modifier and Type	Method	Description
abstract org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext	getApplicationSubmissionContext()	The ApplicationSubmissionContext for the application ApplicationId can be obtained from the this
abstract Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,Long>	getApplicationTimeouts()
ApplicationAttemptStateData	getAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId)
int	getAttemptCount()
abstract org.apache.hadoop.ipc.CallerContext	getCallerContext()
abstract String	getDiagnostics()	Get the diagnostics information for the application master.
abstract long	getFinishTime()	The finish time of the application.
int	getFirstAttemptId()
abstract long	getLaunchTime()	Get the launch time of the application.
abstract org.apache.hadoop.yarn.proto.YarnServerResourceManagerRecoveryProtos.ApplicationStateDataProto	getProto()
abstract String	getRealUser()
abstract long	getStartTime()	Get the start time of the application.
abstract RMAppState	getState()	Get the final state of the application.
abstract long	getSubmitTime()	The time at which the application was received by the Resource Manager
abstract String	getUser()
static ApplicationStateData	newInstance(long submitTime, long startTime, String user, String realUser, org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext, RMAppState state, String diagnostics, long launchTime, long finishTime, org.apache.hadoop.ipc.CallerContext callerContext)
static ApplicationStateData	newInstance(long submitTime, long startTime, String user, String realUser, org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext, RMAppState state, String diagnostics, long launchTime, long finishTime, org.apache.hadoop.ipc.CallerContext callerContext, Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,Long> applicationTimeouts)
static ApplicationStateData	newInstance(long submitTime, long startTime, String user, org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext, RMAppState state, String diagnostics, long launchTime, long finishTime, org.apache.hadoop.ipc.CallerContext callerContext)
static ApplicationStateData	newInstance(long submitTime, long startTime, String user, org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext, RMAppState state, String diagnostics, long launchTime, long finishTime, org.apache.hadoop.ipc.CallerContext callerContext, Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,Long> applicationTimeouts)
static ApplicationStateData	newInstance(long submitTime, long startTime, org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext context, String user)
static ApplicationStateData	newInstance(long submitTime, long startTime, org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext context, String user, String realUser, org.apache.hadoop.ipc.CallerContext callerContext)
static ApplicationStateData	newInstance(long submitTime, long startTime, org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext context, String user, org.apache.hadoop.ipc.CallerContext callerContext)
abstract void	setApplicationSubmissionContext(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext context)
abstract void	setApplicationTimeouts(Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,Long> applicationTimeouts)
abstract void	setCallerContext(org.apache.hadoop.ipc.CallerContext callerContext)
abstract void	setDiagnostics(String diagnostics)
abstract void	setFinishTime(long finishTime)
abstract void	setLaunchTime(long launchTime)
abstract void	setRealUser(String realUser)
abstract void	setStartTime(long startTime)
abstract void	setState(RMAppState state)
abstract void	setSubmitTime(long submitTime)
abstract void	setUser(String user)	The application submitter.

Methods inherited from class java.lang.Object

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

Field Details

attempts

public Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,ApplicationAttemptStateData> attempts

Constructor Details

ApplicationStateData

public ApplicationStateData()

Method Details

newInstance

public static ApplicationStateData newInstance(long submitTime,
 long startTime,
 String user,
 org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext,
 RMAppState state,
 String diagnostics,
 long launchTime,
 long finishTime,
 org.apache.hadoop.ipc.CallerContext callerContext)

newInstance

public static ApplicationStateData newInstance(long submitTime,
 long startTime,
 String user,
 org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext,
 RMAppState state,
 String diagnostics,
 long launchTime,
 long finishTime,
 org.apache.hadoop.ipc.CallerContext callerContext,
 Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,Long> applicationTimeouts)

newInstance

public static ApplicationStateData newInstance(long submitTime,
 long startTime,
 org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext context,
 String user,
 org.apache.hadoop.ipc.CallerContext callerContext)

newInstance

public static ApplicationStateData newInstance(long submitTime,
 long startTime,
 org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext context,
 String user)

newInstance

public static ApplicationStateData newInstance(long submitTime,
 long startTime,
 String user,
 String realUser,
 org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext,
 RMAppState state,
 String diagnostics,
 long launchTime,
 long finishTime,
 org.apache.hadoop.ipc.CallerContext callerContext)

newInstance

public static ApplicationStateData newInstance(long submitTime,
 long startTime,
 String user,
 String realUser,
 org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext,
 RMAppState state,
 String diagnostics,
 long launchTime,
 long finishTime,
 org.apache.hadoop.ipc.CallerContext callerContext,
 Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,Long> applicationTimeouts)

newInstance

public static ApplicationStateData newInstance(long submitTime,
 long startTime,
 org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext context,
 String user,
 String realUser,
 org.apache.hadoop.ipc.CallerContext callerContext)

getAttemptCount

public int getAttemptCount()

getAttempt

public ApplicationAttemptStateData getAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId)

getFirstAttemptId

public int getFirstAttemptId()

getProto

public abstract org.apache.hadoop.yarn.proto.YarnServerResourceManagerRecoveryProtos.ApplicationStateDataProto getProto()

getSubmitTime

@Public
@Unstable
public abstract long getSubmitTime()

The time at which the application was received by the Resource Manager

Returns:

submitTime

setSubmitTime

@Public
@Unstable
public abstract void setSubmitTime(long submitTime)

getStartTime

@Public
@Stable
public abstract long getStartTime()

Get the start time of the application.

Returns:

start time of the application

setStartTime

@Private
@Unstable
public abstract void setStartTime(long startTime)

getLaunchTime

@Public
@Stable
public abstract long getLaunchTime()

Get the launch time of the application.

Returns:

launch time of the application

setLaunchTime

@Private
@Unstable
public abstract void setLaunchTime(long launchTime)

setUser

@Public
@Unstable
public abstract void setUser(String user)

The application submitter.

Parameters:

user - submitter user name.

getUser

@Public
@Unstable
public abstract String getUser()

getApplicationSubmissionContext

@Public
@Unstable
public abstract org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext getApplicationSubmissionContext()

The ApplicationSubmissionContext for the application ApplicationId can be obtained from the this

Returns:

ApplicationSubmissionContext

setApplicationSubmissionContext

@Public
@Unstable
public abstract void setApplicationSubmissionContext(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext context)

getState

public abstract RMAppState getState()

Get the final state of the application.

Returns:

the final state of the application.

setState

public abstract void setState(RMAppState state)

getDiagnostics

public abstract String getDiagnostics()

Get the diagnostics information for the application master.

Returns:

the diagnostics information for the application master.

setDiagnostics

public abstract void setDiagnostics(String diagnostics)

getFinishTime

public abstract long getFinishTime()

The finish time of the application.

Returns:

the finish time of the application.,

setFinishTime

public abstract void setFinishTime(long finishTime)

getCallerContext

public abstract org.apache.hadoop.ipc.CallerContext getCallerContext()

setCallerContext

public abstract void setCallerContext(org.apache.hadoop.ipc.CallerContext callerContext)

getApplicationTimeouts

@Public
public abstract Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,Long> getApplicationTimeouts()

setApplicationTimeouts

@Public
public abstract void setApplicationTimeouts(Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,Long> applicationTimeouts)

getRealUser

public abstract String getRealUser()

setRealUser

public abstract void setRealUser(String realUser)