@InterfaceAudience.Private @InterfaceStability.Unstable public class PreemptionContractPBImpl extends PreemptionContract
Constructor and Description |
---|
PreemptionContractPBImpl() |
PreemptionContractPBImpl(YarnProtos.PreemptionContractProto proto) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object other) |
Set<PreemptionContainer> |
getContainers()
Assign the set of
PreemptionContainer specifying which containers
owned by the ApplicationMaster that may be reclaimed by the
ResourceManager . |
YarnProtos.PreemptionContractProto |
getProto() |
List<PreemptionResourceRequest> |
getResourceRequest()
If the AM releases resources matching these requests, then the
PreemptionContainer s enumerated in PreemptionContract.getContainers() should not be
evicted from the cluster. |
int |
hashCode() |
void |
setContainers(Set<PreemptionContainer> containers) |
void |
setResourceRequest(List<PreemptionResourceRequest> req) |
String |
toString() |
newInstance
public PreemptionContractPBImpl()
public PreemptionContractPBImpl(YarnProtos.PreemptionContractProto proto)
public YarnProtos.PreemptionContractProto getProto()
public Set<PreemptionContainer> getContainers()
PreemptionContract
PreemptionContainer
specifying which containers
owned by the ApplicationMaster
that may be reclaimed by the
ResourceManager
. If the AM prefers a different set of
containers, then it may checkpoint or kill containers matching the
description in PreemptionContract.getResourceRequest()
.getContainers
in class PreemptionContract
public void setContainers(Set<PreemptionContainer> containers)
setContainers
in class PreemptionContract
public List<PreemptionResourceRequest> getResourceRequest()
PreemptionContract
PreemptionContainer
s enumerated in PreemptionContract.getContainers()
should not be
evicted from the cluster. Due to delays in propagating cluster state and
sending these messages, there are conditions where satisfied contracts may
not prevent the platform from killing containers.getResourceRequest
in class PreemptionContract
PreemptionResourceRequest
to update the
ApplicationMaster
about resources requested back by the
ResourceManager
.AllocateRequest.setAskList(List)
public void setResourceRequest(List<PreemptionResourceRequest> req)
setResourceRequest
in class PreemptionContract
Copyright © 2013 Apache Software Foundation. All rights reserved.