Package org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity

Class CSAssignment

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CSAssignment

@Private
@Unstable
public class CSAssignment
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	CSAssignment.SkippedType	Reason for the queue to get skipped.

Field Summary

Fields

Modifier and Type	Field	Description
static final CSAssignment	NULL_ASSIGNMENT
static final CSAssignment	SKIP_ASSIGNMENT

Constructor Summary

Constructors

Constructor	Description
CSAssignment(org.apache.hadoop.yarn.api.records.Resource resource, NodeType type)
CSAssignment(org.apache.hadoop.yarn.api.records.Resource resource, NodeType type, RMContainer excessReservation, FiCaSchedulerApp application, CSAssignment.SkippedType skipped, boolean fulfilledReservation)
CSAssignment(CSAssignment.SkippedType skipped)
CSAssignment(FiCaSchedulerApp application, RMContainer excessReservation)

Method Summary

Modifier and Type	Method	Description
FiCaSchedulerApp	getApplication()
AssignmentInformation	getAssignmentInformation()
List<RMContainer>	getContainersToKill()
RMContainer	getExcessReservation()
RMContainer	getFulfilledReservedContainer()
NodeType	getRequestLocalityType()
org.apache.hadoop.yarn.api.records.Resource	getResource()
SchedulingMode	getSchedulingMode()
CSAssignment.SkippedType	getSkippedType()
NodeType	getType()
boolean	isFulfilledReservation()
boolean	isIncreasedAllocation()
void	setApplication(FiCaSchedulerApp application)
void	setContainersToKill(List<RMContainer> containersToKill)
void	setExcessReservation(RMContainer rmContainer)
void	setFulfilledReservation(boolean fulfilledReservation)
void	setFulfilledReservedContainer(RMContainer fulfilledReservedContainer)
void	setIncreasedAllocation(boolean flag)
void	setRequestLocalityType(NodeType requestLocalityType)
void	setResource(org.apache.hadoop.yarn.api.records.Resource resource)
void	setSchedulingMode(SchedulingMode schedulingMode)
void	setSkippedType(CSAssignment.SkippedType skippedType)
void	setType(NodeType type)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

NULL_ASSIGNMENT

public static final CSAssignment NULL_ASSIGNMENT

SKIP_ASSIGNMENT

public static final CSAssignment SKIP_ASSIGNMENT

Constructor Details

CSAssignment

public CSAssignment(org.apache.hadoop.yarn.api.records.Resource resource,
 NodeType type)

CSAssignment

public CSAssignment(FiCaSchedulerApp application,
 RMContainer excessReservation)

CSAssignment

public CSAssignment(CSAssignment.SkippedType skipped)

CSAssignment

public CSAssignment(org.apache.hadoop.yarn.api.records.Resource resource,
 NodeType type,
 RMContainer excessReservation,
 FiCaSchedulerApp application,
 CSAssignment.SkippedType skipped,
 boolean fulfilledReservation)

Method Details

getResource

public org.apache.hadoop.yarn.api.records.Resource getResource()

setResource

public void setResource(org.apache.hadoop.yarn.api.records.Resource resource)

getType

public NodeType getType()

setType

public void setType(NodeType type)

getApplication

public FiCaSchedulerApp getApplication()

setApplication

public void setApplication(FiCaSchedulerApp application)

getExcessReservation

public RMContainer getExcessReservation()

setExcessReservation

public void setExcessReservation(RMContainer rmContainer)

getSkippedType

public CSAssignment.SkippedType getSkippedType()

setSkippedType

public void setSkippedType(CSAssignment.SkippedType skippedType)

toString

public String toString()

Overrides:

toString in class Object

setFulfilledReservation

public void setFulfilledReservation(boolean fulfilledReservation)

isFulfilledReservation

public boolean isFulfilledReservation()

getAssignmentInformation

public AssignmentInformation getAssignmentInformation()

isIncreasedAllocation

public boolean isIncreasedAllocation()

setIncreasedAllocation

public void setIncreasedAllocation(boolean flag)

setContainersToKill

public void setContainersToKill(List<RMContainer> containersToKill)

getContainersToKill

public List<RMContainer> getContainersToKill()

getFulfilledReservedContainer

public RMContainer getFulfilledReservedContainer()

setFulfilledReservedContainer

public void setFulfilledReservedContainer(RMContainer fulfilledReservedContainer)

getSchedulingMode

public SchedulingMode getSchedulingMode()

setSchedulingMode

public void setSchedulingMode(SchedulingMode schedulingMode)

getRequestLocalityType

public NodeType getRequestLocalityType()

setRequestLocalityType

public void setRequestLocalityType(NodeType requestLocalityType)