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

Class ApplicationAttemptStateDataPBImpl

java.lang.Object

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

org.apache.hadoop.yarn.server.resourcemanager.recovery.records.impl.pb.ApplicationAttemptStateDataPBImpl

public class ApplicationAttemptStateDataPBImpl
extends ApplicationAttemptStateData

Constructor Summary

Constructors

Constructor	Description
ApplicationAttemptStateDataPBImpl()
ApplicationAttemptStateDataPBImpl(org.apache.hadoop.yarn.proto.YarnServerResourceManagerRecoveryProtos.ApplicationAttemptStateDataProto proto)

Method Summary

Modifier and Type	Method	Description
static RMAppAttemptState	convertFromProtoFormat(org.apache.hadoop.yarn.proto.YarnServerResourceManagerRecoveryProtos.RMAppAttemptStateProto e)
static org.apache.hadoop.yarn.proto.YarnServerResourceManagerRecoveryProtos.RMAppAttemptStateProto	convertToProtoFormat(RMAppAttemptState e)
boolean	equals(Object other)
int	getAMContainerExitStatus()
org.apache.hadoop.security.Credentials	getAppAttemptTokens()	The application attempt tokens that belong to this attempt
org.apache.hadoop.yarn.api.records.ApplicationAttemptId	getAttemptId()	The ApplicationAttemptId for the application attempt
String	getDiagnostics()	Get the diagnositic information of the attempt
org.apache.hadoop.yarn.api.records.FinalApplicationStatus	getFinalApplicationStatus()	Get the final finish status of the application.
String	getFinalTrackingUrl()	Get the original not-proxied final tracking url for the application.
long	getFinishTime()	Get the finish time of the application attempt.
org.apache.hadoop.yarn.api.records.Container	getMasterContainer()
long	getMemorySeconds()	Get the memory seconds (in MB seconds) of the application.
long	getPreemptedMemorySeconds()	Get the preempted memory seconds (in MB seconds) of the application.
Map<String,Long>	getPreemptedResourceSecondsMap()	Get the aggregated number of resources preempted that the application has allocated times the number of seconds the application has been running.
long	getPreemptedVcoreSeconds()	Get the preempted vcore seconds of the application.
org.apache.hadoop.yarn.proto.YarnServerResourceManagerRecoveryProtos.ApplicationAttemptStateDataProto	getProto()
Map<String,Long>	getResourceSecondsMap()	Get the aggregated number of resources preempted that the application has allocated times the number of seconds the application has been running.
long	getStartTime()	Get the start time of the application.
RMAppAttemptState	getState()	Get the final state of the application attempt.
int	getTotalAllocatedContainers()	Get total number of containers allocated for this attempt.
long	getVcoreSeconds()	Get the vcore seconds of the application.
int	hashCode()
void	setAMContainerExitStatus(int exitStatus)
void	setAppAttemptTokens(org.apache.hadoop.security.Credentials attemptTokens)
void	setAttemptId(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId)
void	setDiagnostics(String diagnostics)
void	setFinalApplicationStatus(org.apache.hadoop.yarn.api.records.FinalApplicationStatus finishState)
void	setFinalTrackingUrl(String url)	Set the final tracking Url of the AM.
void	setFinishTime(long finishTime)
void	setMasterContainer(org.apache.hadoop.yarn.api.records.Container container)
void	setMemorySeconds(long memorySeconds)
void	setPreemptedMemorySeconds(long memorySeconds)
void	setPreemptedResourceSecondsMap(Map<String,Long> preemptedResourceSecondsMap)	Set the aggregated number of resources preempted that the application has allocated times the number of seconds the application has been running.
void	setPreemptedVcoreSeconds(long vcoreSeconds)
void	setResourceSecondsMap(Map<String,Long> resourceSecondsMap)	Set the aggregated number of resources that the application has allocated times the number of seconds the application has been running.
void	setStartTime(long startTime)
void	setState(RMAppAttemptState state)
void	setTotalAllocatedContainers(int totalAllocatedContainers)	Set total number of containers allocated for this attempt.
void	setVcoreSeconds(long vcoreSeconds)
String	toString()

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.recovery.records.ApplicationAttemptStateData

newInstance, newInstance

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

ApplicationAttemptStateDataPBImpl

public ApplicationAttemptStateDataPBImpl()

ApplicationAttemptStateDataPBImpl

public ApplicationAttemptStateDataPBImpl(org.apache.hadoop.yarn.proto.YarnServerResourceManagerRecoveryProtos.ApplicationAttemptStateDataProto proto)

Method Details

getProto

public org.apache.hadoop.yarn.proto.YarnServerResourceManagerRecoveryProtos.ApplicationAttemptStateDataProto getProto()

Specified by:

getProto in class ApplicationAttemptStateData

getAttemptId

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

Description copied from class: ApplicationAttemptStateData

The ApplicationAttemptId for the application attempt

Specified by:

getAttemptId in class ApplicationAttemptStateData

Returns:

ApplicationAttemptId for the application attempt

setAttemptId

public void setAttemptId(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId)

Specified by:

setAttemptId in class ApplicationAttemptStateData

getMasterContainer

public org.apache.hadoop.yarn.api.records.Container getMasterContainer()

Specified by:

getMasterContainer in class ApplicationAttemptStateData

setMasterContainer

public void setMasterContainer(org.apache.hadoop.yarn.api.records.Container container)

Specified by:

setMasterContainer in class ApplicationAttemptStateData

getAppAttemptTokens

public org.apache.hadoop.security.Credentials getAppAttemptTokens()

Description copied from class: ApplicationAttemptStateData

The application attempt tokens that belong to this attempt

Specified by:

getAppAttemptTokens in class ApplicationAttemptStateData

Returns:

The application attempt tokens that belong to this attempt

setAppAttemptTokens

public void setAppAttemptTokens(org.apache.hadoop.security.Credentials attemptTokens)

Specified by:

setAppAttemptTokens in class ApplicationAttemptStateData

getState

public RMAppAttemptState getState()

Description copied from class: ApplicationAttemptStateData

Get the final state of the application attempt.

Specified by:

getState in class ApplicationAttemptStateData

Returns:

the final state of the application attempt.

setState

public void setState(RMAppAttemptState state)

Specified by:

setState in class ApplicationAttemptStateData

getFinalTrackingUrl

public String getFinalTrackingUrl()

Description copied from class: ApplicationAttemptStateData

Get the original not-proxied final tracking url for the application. This is intended to only be used by the proxy itself.

Specified by:

getFinalTrackingUrl in class ApplicationAttemptStateData

Returns:

the original not-proxied final tracking url for the application

setFinalTrackingUrl

public void setFinalTrackingUrl(String url)

Description copied from class: ApplicationAttemptStateData

Set the final tracking Url of the AM.

Specified by:

setFinalTrackingUrl in class ApplicationAttemptStateData

Parameters:

url - tracking url.

getDiagnostics

public String getDiagnostics()

Description copied from class: ApplicationAttemptStateData

Get the diagnositic information of the attempt

Specified by:

getDiagnostics in class ApplicationAttemptStateData

Returns:

diagnositic information of the attempt

setDiagnostics

public void setDiagnostics(String diagnostics)

Specified by:

setDiagnostics in class ApplicationAttemptStateData

getStartTime

public long getStartTime()

Description copied from class: ApplicationAttemptStateData

Get the start time of the application.

Specified by:

getStartTime in class ApplicationAttemptStateData

Returns:

start time of the application

setStartTime

public void setStartTime(long startTime)

Specified by:

setStartTime in class ApplicationAttemptStateData

getMemorySeconds

public long getMemorySeconds()

Description copied from class: ApplicationAttemptStateData

Get the memory seconds (in MB seconds) of the application.

Specified by:

getMemorySeconds in class ApplicationAttemptStateData

Returns:

memory seconds (in MB seconds) of the application

getVcoreSeconds

public long getVcoreSeconds()

Description copied from class: ApplicationAttemptStateData

Get the vcore seconds of the application.

Specified by:

getVcoreSeconds in class ApplicationAttemptStateData

Returns:

vcore seconds of the application

setMemorySeconds

public void setMemorySeconds(long memorySeconds)

Specified by:

setMemorySeconds in class ApplicationAttemptStateData

setVcoreSeconds

public void setVcoreSeconds(long vcoreSeconds)

Specified by:

setVcoreSeconds in class ApplicationAttemptStateData

getPreemptedMemorySeconds

public long getPreemptedMemorySeconds()

Description copied from class: ApplicationAttemptStateData

Get the preempted memory seconds (in MB seconds) of the application.

Specified by:

getPreemptedMemorySeconds in class ApplicationAttemptStateData

Returns:

preempted memory seconds (in MB seconds) of the application

getPreemptedVcoreSeconds

public long getPreemptedVcoreSeconds()

Description copied from class: ApplicationAttemptStateData

Get the preempted vcore seconds of the application.

Specified by:

getPreemptedVcoreSeconds in class ApplicationAttemptStateData

Returns:

preempted vcore seconds of the application

setPreemptedMemorySeconds

public void setPreemptedMemorySeconds(long memorySeconds)

Specified by:

setPreemptedMemorySeconds in class ApplicationAttemptStateData

setPreemptedVcoreSeconds

public void setPreemptedVcoreSeconds(long vcoreSeconds)

Specified by:

setPreemptedVcoreSeconds in class ApplicationAttemptStateData

getFinalApplicationStatus

public org.apache.hadoop.yarn.api.records.FinalApplicationStatus getFinalApplicationStatus()

Description copied from class: ApplicationAttemptStateData

Get the final finish status of the application.

Specified by:

getFinalApplicationStatus in class ApplicationAttemptStateData

Returns:

final finish status of the application

setFinalApplicationStatus

public void setFinalApplicationStatus(org.apache.hadoop.yarn.api.records.FinalApplicationStatus finishState)

Specified by:

setFinalApplicationStatus in class ApplicationAttemptStateData

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getAMContainerExitStatus

public int getAMContainerExitStatus()

Specified by:

getAMContainerExitStatus in class ApplicationAttemptStateData

setAMContainerExitStatus

public void setAMContainerExitStatus(int exitStatus)

Specified by:

setAMContainerExitStatus in class ApplicationAttemptStateData

equals

public boolean equals(Object other)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

convertToProtoFormat

public static org.apache.hadoop.yarn.proto.YarnServerResourceManagerRecoveryProtos.RMAppAttemptStateProto convertToProtoFormat(RMAppAttemptState e)

convertFromProtoFormat

public static RMAppAttemptState convertFromProtoFormat(org.apache.hadoop.yarn.proto.YarnServerResourceManagerRecoveryProtos.RMAppAttemptStateProto e)

getFinishTime

public long getFinishTime()

Description copied from class: ApplicationAttemptStateData

Get the finish time of the application attempt.

Specified by:

getFinishTime in class ApplicationAttemptStateData

Returns:

finish time of the application attempt

setFinishTime

public void setFinishTime(long finishTime)

Specified by:

setFinishTime in class ApplicationAttemptStateData

getResourceSecondsMap

public Map<String,Long> getResourceSecondsMap()

Description copied from class: ApplicationAttemptStateData

Get the aggregated number of resources preempted that the application has allocated times the number of seconds the application has been running.

Specified by:

getResourceSecondsMap in class ApplicationAttemptStateData

Returns:

map containing the resource name and aggregated preempted resource-seconds

setResourceSecondsMap

public void setResourceSecondsMap(Map<String,Long> resourceSecondsMap)

Description copied from class: ApplicationAttemptStateData

Set the aggregated number of resources that the application has allocated times the number of seconds the application has been running.

Specified by:

setResourceSecondsMap in class ApplicationAttemptStateData

Parameters:

resourceSecondsMap - map containing the resource name and aggregated resource-seconds

getPreemptedResourceSecondsMap

public Map<String,Long> getPreemptedResourceSecondsMap()

Description copied from class: ApplicationAttemptStateData

Get the aggregated number of resources preempted that the application has allocated times the number of seconds the application has been running.

Specified by:

getPreemptedResourceSecondsMap in class ApplicationAttemptStateData

Returns:

map containing the resource name and aggregated preempted resource-seconds

setPreemptedResourceSecondsMap

public void setPreemptedResourceSecondsMap(Map<String,Long> preemptedResourceSecondsMap)

Description copied from class: ApplicationAttemptStateData

Set the aggregated number of resources preempted that the application has allocated times the number of seconds the application has been running.

Specified by:

setPreemptedResourceSecondsMap in class ApplicationAttemptStateData

Parameters:

preemptedResourceSecondsMap - map containing the resource name and aggregated preempted resource-seconds

getTotalAllocatedContainers

public int getTotalAllocatedContainers()

Description copied from class: ApplicationAttemptStateData

Get total number of containers allocated for this attempt.

Specified by:

getTotalAllocatedContainers in class ApplicationAttemptStateData

Returns:

total number of containers allocated for this attempt.

setTotalAllocatedContainers

public void setTotalAllocatedContainers(int totalAllocatedContainers)

Description copied from class: ApplicationAttemptStateData

Set total number of containers allocated for this attempt.

Specified by:

setTotalAllocatedContainers in class ApplicationAttemptStateData

Parameters:

totalAllocatedContainers - total number of containers