org.apache.hadoop.yarn.api.records.impl.pb

Class PreemptionContractPBImpl

java.lang.Object

org.apache.hadoop.yarn.api.records.PreemptionContract

org.apache.hadoop.yarn.api.records.impl.pb.PreemptionContractPBImpl

@InterfaceAudience.Private
@InterfaceStability.Unstable
public class PreemptionContractPBImpl
extends PreemptionContract

Constructor Summary

Constructors

Constructor and Description
PreemptionContractPBImpl()
PreemptionContractPBImpl(YarnProtos.PreemptionContractProto proto)

Method Summary

Methods

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 PreemptionContainers 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()

Methods inherited from class org.apache.hadoop.yarn.api.records.PreemptionContract

newInstance

Methods inherited from class java.lang.Object

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

Constructor Detail

PreemptionContractPBImpl

public PreemptionContractPBImpl()

PreemptionContractPBImpl

public PreemptionContractPBImpl(YarnProtos.PreemptionContractProto proto)

Method Detail

getProto

public YarnProtos.PreemptionContractProto getProto()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

getContainers

public Set<PreemptionContainer> getContainers()

Description copied from class: PreemptionContract

Assign the set of 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().

Specified by:

getContainers in class PreemptionContract

Returns:

Set of containers at risk if the contract is not met.

setContainers

public void setContainers(Set<PreemptionContainer> containers)

Specified by:

setContainers in class PreemptionContract

getResourceRequest

public List<PreemptionResourceRequest> getResourceRequest()

Description copied from class: PreemptionContract

If the AM releases resources matching these requests, then the PreemptionContainers 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.

Specified by:

getResourceRequest in class PreemptionContract

Returns:

List of PreemptionResourceRequest to update the ApplicationMaster about resources requested back by the ResourceManager.

See Also:

AllocateRequest.setAskList(List)

setResourceRequest

public void setResourceRequest(List<PreemptionResourceRequest> req)

Specified by:

setResourceRequest in class PreemptionContract