Package org.apache.hadoop.yarn.server.applicationhistoryservice

Class NullApplicationHistoryStore

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.yarn.server.applicationhistoryservice.NullApplicationHistoryStore

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service, ApplicationHistoryReader, ApplicationHistoryStore, ApplicationHistoryWriter

@Unstable
@Private
public class NullApplicationHistoryStore
extends org.apache.hadoop.service.AbstractService
implements ApplicationHistoryStore

Dummy implementation of ApplicationHistoryStore. If this implementation is used, no history data will be persisted.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Constructor Summary

Constructors

Constructor	Description
NullApplicationHistoryStore()

Method Summary

Modifier and Type	Method	Description
void	applicationAttemptFinished(ApplicationAttemptFinishData appAttemptFinish)	This method writes the information of RMAppAttempt that is available when it finishes.
void	applicationAttemptStarted(ApplicationAttemptStartData appAttemptStart)	This method writes the information of RMAppAttempt that is available when it starts.
void	applicationFinished(ApplicationFinishData appFinish)	This method writes the information of RMApp that is available when it finishes.
void	applicationStarted(ApplicationStartData appStart)	This method writes the information of RMApp that is available when it starts.
void	containerFinished(ContainerFinishData containerFinish)	This method writes the information of RMContainer that is available when it finishes.
void	containerStarted(ContainerStartData containerStart)	This method writes the information of RMContainer that is available when it starts.
Map<org.apache.hadoop.yarn.api.records.ApplicationId,ApplicationHistoryData>	getAllApplications()	This method returns all Application ApplicationHistoryDatas
ContainerHistoryData	getAMContainer(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)	This method returns ContainerHistoryData for specified ApplicationAttemptId.
ApplicationHistoryData	getApplication(org.apache.hadoop.yarn.api.records.ApplicationId appId)	This method returns Application ApplicationHistoryData for the specified ApplicationId.
ApplicationAttemptHistoryData	getApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)	This method returns ApplicationAttemptHistoryData for specified ApplicationId.
Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,ApplicationAttemptHistoryData>	getApplicationAttempts(org.apache.hadoop.yarn.api.records.ApplicationId appId)	Application can have multiple application attempts ApplicationAttemptHistoryData.
ContainerHistoryData	getContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)	This method returns ContainerHistoryData for specified ContainerId.
Map<org.apache.hadoop.yarn.api.records.ContainerId,ContainerHistoryData>	getContainers(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)	This method returns MapContainerId to ContainerHistoryData for specified ApplicationAttemptId.

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, serviceStart, serviceStop, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.service.Service

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, registerServiceListener, start, stop, unregisterServiceListener, waitForServiceToStop

Constructor Details

NullApplicationHistoryStore

public NullApplicationHistoryStore()

Method Details

applicationStarted

public void applicationStarted(ApplicationStartData appStart)
                        throws IOException

Description copied from interface: ApplicationHistoryWriter

This method writes the information of RMApp that is available when it starts.

Specified by:

applicationStarted in interface ApplicationHistoryWriter

Parameters:

appStart - the record of the information of RMApp that is available when it starts

Throws:

IOException

applicationFinished

public void applicationFinished(ApplicationFinishData appFinish)
                         throws IOException

Description copied from interface: ApplicationHistoryWriter

This method writes the information of RMApp that is available when it finishes.

Specified by:

applicationFinished in interface ApplicationHistoryWriter

Parameters:

appFinish - the record of the information of RMApp that is available when it finishes

Throws:

IOException

applicationAttemptStarted

public void applicationAttemptStarted(ApplicationAttemptStartData appAttemptStart)
                               throws IOException

Description copied from interface: ApplicationHistoryWriter

This method writes the information of RMAppAttempt that is available when it starts.

Specified by:

applicationAttemptStarted in interface ApplicationHistoryWriter

Parameters:

appAttemptStart - the record of the information of RMAppAttempt that is available when it starts

Throws:

IOException

applicationAttemptFinished

public void applicationAttemptFinished(ApplicationAttemptFinishData appAttemptFinish)
                                throws IOException

Description copied from interface: ApplicationHistoryWriter

This method writes the information of RMAppAttempt that is available when it finishes.

Specified by:

applicationAttemptFinished in interface ApplicationHistoryWriter

Parameters:

appAttemptFinish - the record of the information of RMAppAttempt that is available when it finishes

Throws:

IOException

containerStarted

public void containerStarted(ContainerStartData containerStart)
                      throws IOException

Description copied from interface: ApplicationHistoryWriter

This method writes the information of RMContainer that is available when it starts.

Specified by:

containerStarted in interface ApplicationHistoryWriter

Parameters:

containerStart - the record of the information of RMContainer that is available when it starts

Throws:

IOException

containerFinished

public void containerFinished(ContainerFinishData containerFinish)
                       throws IOException

Description copied from interface: ApplicationHistoryWriter

This method writes the information of RMContainer that is available when it finishes.

Specified by:

containerFinished in interface ApplicationHistoryWriter

Parameters:

containerFinish - the record of the information of RMContainer that is available when it finishes

Throws:

IOException

getApplication

public ApplicationHistoryData getApplication(org.apache.hadoop.yarn.api.records.ApplicationId appId)
                                      throws IOException

Description copied from interface: ApplicationHistoryReader

This method returns Application ApplicationHistoryData for the specified ApplicationId.

Specified by:

getApplication in interface ApplicationHistoryReader

Returns:

ApplicationHistoryData for the ApplicationId.

Throws:

IOException

getAllApplications

public Map<org.apache.hadoop.yarn.api.records.ApplicationId,ApplicationHistoryData> getAllApplications()
                                                                                                throws IOException

Description copied from interface: ApplicationHistoryReader

This method returns all Application ApplicationHistoryDatas

Specified by:

getAllApplications in interface ApplicationHistoryReader

Returns:

map of ApplicationId to ApplicationHistoryDatas.

Throws:

IOException

getApplicationAttempts

public Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,ApplicationAttemptHistoryData> getApplicationAttempts(org.apache.hadoop.yarn.api.records.ApplicationId appId)
                                                                                                                  throws IOException

Description copied from interface: ApplicationHistoryReader

Application can have multiple application attempts ApplicationAttemptHistoryData. This method returns the all ApplicationAttemptHistoryDatas for the Application.

Specified by:

getApplicationAttempts in interface ApplicationHistoryReader

Returns:

all ApplicationAttemptHistoryDatas for the Application.

Throws:

IOException

getApplicationAttempt

public ApplicationAttemptHistoryData getApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)
                                                    throws IOException

Description copied from interface: ApplicationHistoryReader

This method returns ApplicationAttemptHistoryData for specified ApplicationId.

Specified by:

getApplicationAttempt in interface ApplicationHistoryReader

Parameters:

appAttemptId - ApplicationAttemptId

Returns:

ApplicationAttemptHistoryData for ApplicationAttemptId

Throws:

IOException

getContainer

public ContainerHistoryData getContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
                                  throws IOException

Description copied from interface: ApplicationHistoryReader

This method returns ContainerHistoryData for specified ContainerId.

Specified by:

getContainer in interface ApplicationHistoryReader

Parameters:

containerId - ContainerId

Returns:

ContainerHistoryData for ContainerId

Throws:

IOException

getAMContainer

public ContainerHistoryData getAMContainer(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)
                                    throws IOException

Description copied from interface: ApplicationHistoryReader

This method returns ContainerHistoryData for specified ApplicationAttemptId.

Specified by:

getAMContainer in interface ApplicationHistoryReader

Parameters:

appAttemptId - ApplicationAttemptId

Returns:

ContainerHistoryData for ApplicationAttemptId

Throws:

IOException

getContainers

public Map<org.apache.hadoop.yarn.api.records.ContainerId,ContainerHistoryData> getContainers(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)
                                                                                       throws IOException

Description copied from interface: ApplicationHistoryReader

This method returns MapContainerId to ContainerHistoryData for specified ApplicationAttemptId.

Specified by:

getContainers in interface ApplicationHistoryReader

Parameters:

appAttemptId - ApplicationAttemptId

Returns:

MapContainerId to ContainerHistoryData for ApplicationAttemptId

Throws:

IOException