org.apache.hadoop.yarn.api.protocolrecords

クラス AllocateRequest

java.lang.Object

org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract class AllocateRequest
extends Object

The core request sent by the ApplicationMaster to the ResourceManager to obtain resources in the cluster.

The request includes:

• A response id to track duplicate responses.
• Progress information.
• A list of ResourceRequest to inform the ResourceManager about the application's resource requirements.
• A list of unused Container which are being returned.
• A list of UpdateContainerRequest to inform the ResourceManager about the change in requirements of running containers.

関連項目:

ApplicationMasterProtocol.allocate(AllocateRequest)

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
AllocateRequest()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
abstract List<ResourceRequest>	getAskList() Get the list of ResourceRequest to update the ResourceManager about the application's resource requirements.
abstract float	getProgress() Get the current progress of application.
abstract List<ContainerId>	getReleaseList() Get the list of ContainerId of containers being released by the ApplicationMaster.
abstract ResourceBlacklistRequest	getResourceBlacklistRequest() Get the ResourceBlacklistRequest being sent by the ApplicationMaster.
abstract int	getResponseId() Get the response id used to track duplicate responses.
abstract List<UpdateContainerRequest>	getUpdateRequests() Get the list of container update requests being sent by the ApplicationMaster.
static AllocateRequest	newInstance(int responseID, float appProgress, List<ResourceRequest> resourceAsk, List<ContainerId> containersToBeReleased, ResourceBlacklistRequest resourceBlacklistRequest)
static AllocateRequest	newInstance(int responseID, float appProgress, List<ResourceRequest> resourceAsk, List<ContainerId> containersToBeReleased, ResourceBlacklistRequest resourceBlacklistRequest, List<UpdateContainerRequest> updateRequests)
abstract void	setAskList(List<ResourceRequest> resourceRequests) Set list of ResourceRequest to update the ResourceManager about the application's resource requirements.
abstract void	setProgress(float progress) Set the current progress of application
abstract void	setReleaseList(List<ContainerId> releaseContainers) Set the list of ContainerId of containers being released by the ApplicationMaster
abstract void	setResourceBlacklistRequest(ResourceBlacklistRequest resourceBlacklistRequest) Set the ResourceBlacklistRequest to inform the ResourceManager about the blacklist additions and removals per the ApplicationMaster.
abstract void	setResponseId(int id) Set the response id used to track duplicate responses.
abstract void	setUpdateRequests(List<UpdateContainerRequest> updateRequests) Set the list of container update requests to inform the ResourceManager about the containers that need to be updated.

クラスから継承されたメソッド java.lang.Object

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

コンストラクタの詳細

AllocateRequest

public AllocateRequest()

メソッドの詳細

newInstance

@InterfaceAudience.Public
 @InterfaceStability.Stable
public static AllocateRequest newInstance(int responseID,
                                                                                                float appProgress,
                                                                                                List<ResourceRequest> resourceAsk,
                                                                                                List<ContainerId> containersToBeReleased,
                                                                                                ResourceBlacklistRequest resourceBlacklistRequest)

newInstance

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public static AllocateRequest newInstance(int responseID,
                                                                                                  float appProgress,
                                                                                                  List<ResourceRequest> resourceAsk,
                                                                                                  List<ContainerId> containersToBeReleased,
                                                                                                  ResourceBlacklistRequest resourceBlacklistRequest,
                                                                                                  List<UpdateContainerRequest> updateRequests)

getResponseId

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract int getResponseId()

Get the response id used to track duplicate responses.

戻り値:

response id

setResponseId

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract void setResponseId(int id)

Set the response id used to track duplicate responses.

パラメータ:

id - response id

getProgress

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract float getProgress()

Get the current progress of application.

戻り値:

current progress of application

setProgress

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract void setProgress(float progress)

Set the current progress of application

パラメータ:

progress - current progress of application

getAskList

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract List<ResourceRequest> getAskList()

Get the list of ResourceRequest to update the ResourceManager about the application's resource requirements.

戻り値:

the list of ResourceRequest

関連項目:

ResourceRequest

setAskList

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract void setAskList(List<ResourceRequest> resourceRequests)

Set list of ResourceRequest to update the ResourceManager about the application's resource requirements.

パラメータ:

resourceRequests - list of ResourceRequest to update the ResourceManager about the application's resource requirements

関連項目:

ResourceRequest

getReleaseList

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract List<ContainerId> getReleaseList()

Get the list of ContainerId of containers being released by the ApplicationMaster.

戻り値:

list of ContainerId of containers being released by the ApplicationMaster

setReleaseList

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract void setReleaseList(List<ContainerId> releaseContainers)

Set the list of ContainerId of containers being released by the ApplicationMaster

パラメータ:

releaseContainers - list of ContainerId of containers being released by the ApplicationMaster

getResourceBlacklistRequest

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract ResourceBlacklistRequest getResourceBlacklistRequest()

Get the ResourceBlacklistRequest being sent by the ApplicationMaster.

戻り値:

the ResourceBlacklistRequest being sent by the ApplicationMaster

関連項目:

ResourceBlacklistRequest

setResourceBlacklistRequest

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract void setResourceBlacklistRequest(ResourceBlacklistRequest resourceBlacklistRequest)

Set the ResourceBlacklistRequest to inform the ResourceManager about the blacklist additions and removals per the ApplicationMaster.

パラメータ:

resourceBlacklistRequest - the ResourceBlacklistRequest to inform the ResourceManager about the blacklist additions and removals per the ApplicationMaster

関連項目:

ResourceBlacklistRequest

getUpdateRequests

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public abstract List<UpdateContainerRequest> getUpdateRequests()

Get the list of container update requests being sent by the ApplicationMaster.

戻り値:

list of UpdateContainerRequest being sent by the ApplicationMaster.

setUpdateRequests

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public abstract void setUpdateRequests(List<UpdateContainerRequest> updateRequests)

Set the list of container update requests to inform the ResourceManager about the containers that need to be updated.

パラメータ:

updateRequests - list of UpdateContainerRequest for containers to be updated