Package | Description |
---|---|
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair | |
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.policies |
Modifier and Type | Class and Description |
---|---|
class |
AppSchedulable |
class |
FSLeafQueue |
class |
FSParentQueue |
class |
FSQueue |
Modifier and Type | Method and Description |
---|---|
abstract Comparator<Schedulable> |
SchedulingPolicy.getComparator()
The comparator returned by this method is to be used for sorting the
Schedulable s in that queue. |
Modifier and Type | Method and Description |
---|---|
abstract void |
SchedulingPolicy.computeShares(Collection<? extends Schedulable> schedulables,
Resource totalResources)
Computes and updates the shares of
Schedulable s as per the
SchedulingPolicy , to be used later at schedule time. |
Modifier and Type | Method and Description |
---|---|
Comparator<Schedulable> |
FairSharePolicy.getComparator() |
Comparator<Schedulable> |
FifoPolicy.getComparator() |
Comparator<Schedulable> |
DominantResourceFairnessPolicy.getComparator() |
Modifier and Type | Method and Description |
---|---|
int |
DominantResourceFairnessPolicy.DominantResourceFairnessComparator.compare(Schedulable s1,
Schedulable s2) |
Modifier and Type | Method and Description |
---|---|
void |
FairSharePolicy.computeShares(Collection<? extends Schedulable> schedulables,
Resource totalResources) |
void |
FifoPolicy.computeShares(Collection<? extends Schedulable> schedulables,
Resource totalResources) |
void |
DominantResourceFairnessPolicy.computeShares(Collection<? extends Schedulable> schedulables,
Resource totalResources) |
static void |
ComputeFairShares.computeShares(Collection<? extends Schedulable> schedulables,
Resource totalResources,
ResourceType type)
Given a set of Schedulables and a number of slots, compute their weighted
fair shares.
|
Copyright © 2013 Apache Software Foundation. All rights reserved.