|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.hadoop.yarn.api.protocolrecords.AllocateRequest
@InterfaceAudience.Public @InterfaceStability.Stable public abstract class AllocateRequest
The core request sent by the ApplicationMaster to the
ResourceManager to obtain resources in the cluster.
The request includes:
ResourceRequest to inform the
ResourceManager about the application's
resource requirements.
Container which are being returned.
ApplicationMasterProtocol.allocate(AllocateRequest)| Constructor Summary | |
|---|---|
AllocateRequest()
|
|
| Method Summary | |
|---|---|
abstract List<ResourceRequest> |
getAskList()
Get the list of ResourceRequest to update the
ResourceManager about the application's resource requirements. |
abstract List<ContainerResourceIncreaseRequest> |
getIncreaseRequests()
Get the ContainerResourceIncreaseRequest being sent by the
ApplicationMaster |
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. |
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<ContainerResourceIncreaseRequest> increaseRequests)
|
abstract void |
setAskList(List<ResourceRequest> resourceRequests)
Set list of ResourceRequest to update the
ResourceManager about the application's resource requirements. |
abstract void |
setIncreaseRequests(List<ContainerResourceIncreaseRequest> increaseRequests)
Set the ContainerResourceIncreaseRequest to inform the
ResourceManager about some container's resources need to be
increased |
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. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public AllocateRequest()
| Method Detail |
|---|
@InterfaceAudience.Public
@InterfaceStability.Stable
public static AllocateRequest newInstance(int responseID,
float appProgress,
List<ResourceRequest> resourceAsk,
List<ContainerId> containersToBeReleased,
ResourceBlacklistRequest resourceBlacklistRequest)
@InterfaceAudience.Public
@InterfaceStability.Stable
public static AllocateRequest newInstance(int responseID,
float appProgress,
List<ResourceRequest> resourceAsk,
List<ContainerId> containersToBeReleased,
ResourceBlacklistRequest resourceBlacklistRequest,
List<ContainerResourceIncreaseRequest> increaseRequests)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract int getResponseId()
@InterfaceAudience.Public @InterfaceStability.Stable public abstract void setResponseId(int id)
id - response id@InterfaceAudience.Public @InterfaceStability.Stable public abstract float getProgress()
@InterfaceAudience.Public @InterfaceStability.Stable public abstract void setProgress(float progress)
progress - current progress of application@InterfaceAudience.Public @InterfaceStability.Stable public abstract List<ResourceRequest> getAskList()
ResourceRequest to update the
ResourceManager about the application's resource requirements.
ResourceRequestResourceRequest@InterfaceAudience.Public @InterfaceStability.Stable public abstract void setAskList(List<ResourceRequest> resourceRequests)
ResourceRequest to update the
ResourceManager about the application's resource requirements.
resourceRequests - list of ResourceRequest to update the
ResourceManager about the application's
resource requirementsResourceRequest@InterfaceAudience.Public @InterfaceStability.Stable public abstract List<ContainerId> getReleaseList()
ContainerId of containers being
released by the ApplicationMaster.
ContainerId of containers being
released by the ApplicationMaster@InterfaceAudience.Public @InterfaceStability.Stable public abstract void setReleaseList(List<ContainerId> releaseContainers)
ContainerId of containers being
released by the ApplicationMaster
releaseContainers - list of ContainerId of
containers being released by the
ApplicationMaster@InterfaceAudience.Public @InterfaceStability.Stable public abstract ResourceBlacklistRequest getResourceBlacklistRequest()
ResourceBlacklistRequest being sent by the
ApplicationMaster.
ResourceBlacklistRequest being sent by the
ApplicationMasterResourceBlacklistRequest@InterfaceAudience.Public @InterfaceStability.Stable public abstract void setResourceBlacklistRequest(ResourceBlacklistRequest resourceBlacklistRequest)
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 ApplicationMasterResourceBlacklistRequest@InterfaceAudience.Public @InterfaceStability.Stable public abstract List<ContainerResourceIncreaseRequest> getIncreaseRequests()
ContainerResourceIncreaseRequest being sent by the
ApplicationMaster
@InterfaceAudience.Public @InterfaceStability.Stable public abstract void setIncreaseRequests(List<ContainerResourceIncreaseRequest> increaseRequests)
ContainerResourceIncreaseRequest to inform the
ResourceManager about some container's resources need to be
increased
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||