public class FifoOrderingPolicyForPendingApps<S extends SchedulableEntity> extends AbstractComparatorOrderingPolicy<S>
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)
comparator, entitiesToReorder, schedulableEntities
Constructor and Description |
---|
FifoOrderingPolicyForPendingApps() |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,String> conf)
Provides configuration information for the policy from the scheduler
configuration
|
void |
containerAllocated(S schedulableEntity,
RMContainer r)
The passed SchedulableEntity has been allocated the passed Container,
take appropriate action (depending on comparator, a reordering of the
SchedulableEntity may be required)
|
void |
containerReleased(S schedulableEntity,
RMContainer r)
The passed SchedulableEntity has released the passed Container,
take appropriate action (depending on comparator, a reordering of the
SchedulableEntity may be required)
|
void |
demandUpdated(S schedulableEntity)
Demand Updated for the passed schedulableEntity, reorder if needed.
|
String |
getInfo()
Display information regarding configuration and status
|
addAllSchedulableEntities, addSchedulableEntity, entityRequiresReordering, getAssignmentIterator, getComparator, getNumSchedulableEntities, getPreemptionIterator, getSchedulableEntities, removeSchedulableEntity, reorderSchedulableEntity, reorderScheduleEntities, updateSchedulingResourceUsage
public String getInfo()
OrderingPolicy
getInfo
in interface OrderingPolicy<S extends SchedulableEntity>
getInfo
in class AbstractComparatorOrderingPolicy<S extends SchedulableEntity>
public void configure(Map<String,String> conf)
OrderingPolicy
configure
in interface OrderingPolicy<S extends SchedulableEntity>
configure
in class AbstractComparatorOrderingPolicy<S extends SchedulableEntity>
public void containerAllocated(S schedulableEntity, RMContainer r)
OrderingPolicy
containerAllocated
in interface OrderingPolicy<S extends SchedulableEntity>
containerAllocated
in class AbstractComparatorOrderingPolicy<S extends SchedulableEntity>
public void containerReleased(S schedulableEntity, RMContainer r)
OrderingPolicy
containerReleased
in interface OrderingPolicy<S extends SchedulableEntity>
containerReleased
in class AbstractComparatorOrderingPolicy<S extends SchedulableEntity>
public void demandUpdated(S schedulableEntity)
OrderingPolicy
demandUpdated
in interface OrderingPolicy<S extends SchedulableEntity>
demandUpdated
in class AbstractComparatorOrderingPolicy<S extends SchedulableEntity>
Copyright © 2017 Apache Software Foundation. All Rights Reserved.