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

Class FifoOrderingPolicyForPendingApps<S extends SchedulableEntity>

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.policy.AbstractComparatorOrderingPolicy<S>

org.apache.hadoop.yarn.server.resourcemanager.scheduler.policy.FifoOrderingPolicyForPendingApps<S>

All Implemented Interfaces:

OrderingPolicy<S>

public class FifoOrderingPolicyForPendingApps<S extends SchedulableEntity>
extends AbstractComparatorOrderingPolicy<S>

This ordering policy is used for pending applications only. An OrderingPolicy which orders SchedulableEntities by

• Recovering application
• Priority of an application
• Input order

Example : If schedulableEntities with E1(true,1,1) E2(true,2,2) E3(true,3,3) E4(false,4,4) E5(false,4,5) are added. The ordering policy assignment iterator is in the order of E3(true,3,3) E2(true,2,2) E1(true,1,1) E5(false,5,5) E4(false,4,4)

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.policy.AbstractComparatorOrderingPolicy

comparator, entitiesToReorder, schedulableEntities

Constructor Summary

Constructors

Constructor	Description
FifoOrderingPolicyForPendingApps()

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,String> conf)	Provides configuration information for the policy from the scheduler configuration.
void	containerAllocated(S schedulableEntity, RMContainer r)	Notify the OrderingPolicy that the SchedulableEntity has been allocated the given RMContainer, enabling the OrderingPolicy to take appropriate action.
void	containerReleased(S schedulableEntity, RMContainer r)	Notify the OrderingPolicy that the SchedulableEntity has released the given RMContainer, enabling the OrderingPolicy to take appropriate action.
void	demandUpdated(S schedulableEntity)	Notify the OrderingPolicy that the demand for the SchedulableEntity has been updated, enabling the OrderingPolicy to reorder the SchedulableEntity if needed.
String	getConfigName()	Return configuration name (which will be used to set ordering policy).
String	getInfo()	Return information regarding configuration and status.

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.policy.AbstractComparatorOrderingPolicy

addAllSchedulableEntities, addSchedulableEntity, entityRequiresReordering, getAssignmentIterator, getComparator, getNumSchedulableEntities, getPreemptionIterator, getSchedulableEntities, removeSchedulableEntity, reorderSchedulableEntity, reorderScheduleEntities, updateSchedulingResourceUsage

Methods inherited from class java.lang.Object

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

Constructor Details

FifoOrderingPolicyForPendingApps

public FifoOrderingPolicyForPendingApps()

Method Details

getInfo

public String getInfo()

Description copied from interface: OrderingPolicy

Return information regarding configuration and status.

Specified by:

getInfo in interface OrderingPolicy<S extends SchedulableEntity>

Specified by:

getInfo in class AbstractComparatorOrderingPolicy<S extends SchedulableEntity>

Returns:

configuration and status information

getConfigName

public String getConfigName()

Description copied from interface: OrderingPolicy

Return configuration name (which will be used to set ordering policy).

Specified by:

getConfigName in interface OrderingPolicy<S extends SchedulableEntity>

Specified by:

getConfigName in class AbstractComparatorOrderingPolicy<S extends SchedulableEntity>

Returns:

configuration name

configure

public void configure(Map<String,String> conf)

Description copied from interface: OrderingPolicy

Provides configuration information for the policy from the scheduler configuration.

Specified by:

configure in interface OrderingPolicy<S extends SchedulableEntity>

Specified by:

configure in class AbstractComparatorOrderingPolicy<S extends SchedulableEntity>

Parameters:

conf - a map of scheduler configuration properties and values

containerAllocated

public void containerAllocated(S schedulableEntity,
 RMContainer r)

Description copied from interface: OrderingPolicy

Notify the OrderingPolicy that the SchedulableEntity has been allocated the given RMContainer, enabling the OrderingPolicy to take appropriate action. Depending on the comparator, a reordering of the SchedulableEntity may be required.

Specified by:

containerAllocated in interface OrderingPolicy<S extends SchedulableEntity>

Specified by:

containerAllocated in class AbstractComparatorOrderingPolicy<S extends SchedulableEntity>

Parameters:

schedulableEntity - the SchedulableEntity

r - the allocated RMContainer

containerReleased

public void containerReleased(S schedulableEntity,
 RMContainer r)

Description copied from interface: OrderingPolicy

Notify the OrderingPolicy that the SchedulableEntity has released the given RMContainer, enabling the OrderingPolicy to take appropriate action. Depending on the comparator, a reordering of the SchedulableEntity may be required.

Specified by:

containerReleased in interface OrderingPolicy<S extends SchedulableEntity>

Specified by:

containerReleased in class AbstractComparatorOrderingPolicy<S extends SchedulableEntity>

Parameters:

schedulableEntity - the SchedulableEntity

r - the released RMContainer

demandUpdated

public void demandUpdated(S schedulableEntity)

Description copied from interface: OrderingPolicy

Notify the OrderingPolicy that the demand for the SchedulableEntity has been updated, enabling the OrderingPolicy to reorder the SchedulableEntity if needed.

Specified by:

demandUpdated in interface OrderingPolicy<S extends SchedulableEntity>

Specified by:

demandUpdated in class AbstractComparatorOrderingPolicy<S extends SchedulableEntity>

Parameters:

schedulableEntity - the updated SchedulableEntity