Modifier and Type | Field and Description |
---|---|
protected ResourceScheduler |
ResourceManager.scheduler |
Modifier and Type | Method and Description |
---|---|
protected ResourceScheduler |
ResourceManager.createScheduler() |
ResourceScheduler |
ResourceManager.getResourceScheduler()
return the scheduler.
|
ResourceScheduler |
RMContext.getScheduler() |
ResourceScheduler |
RMActiveServiceContext.getScheduler() |
ResourceScheduler |
RMContextImpl.getScheduler() |
Modifier and Type | Method and Description |
---|---|
protected QueueACLsManager |
ResourceManager.createQueueACLsManager(ResourceScheduler scheduler,
org.apache.hadoop.conf.Configuration conf) |
Constructor and Description |
---|
ResourceManager.SchedulerEventDispatcher(ResourceScheduler scheduler) |
RMActiveServiceContext(org.apache.hadoop.yarn.event.Dispatcher rmDispatcher,
ContainerAllocationExpirer containerAllocationExpirer,
AMLivelinessMonitor amLivelinessMonitor,
AMLivelinessMonitor amFinishingMonitor,
DelegationTokenRenewer delegationTokenRenewer,
AMRMTokenSecretManager appTokenSecretManager,
RMContainerTokenSecretManager containerTokenSecretManager,
NMTokenSecretManagerInRM nmTokenSecretManager,
ClientToAMTokenSecretManagerInRM clientToAMTokenSecretManager,
RMApplicationHistoryWriter rmApplicationHistoryWriter,
ResourceScheduler scheduler) |
RMContextImpl(org.apache.hadoop.yarn.event.Dispatcher rmDispatcher,
ContainerAllocationExpirer containerAllocationExpirer,
AMLivelinessMonitor amLivelinessMonitor,
AMLivelinessMonitor amFinishingMonitor,
DelegationTokenRenewer delegationTokenRenewer,
AMRMTokenSecretManager appTokenSecretManager,
RMContainerTokenSecretManager containerTokenSecretManager,
NMTokenSecretManagerInRM nmTokenSecretManager,
ClientToAMTokenSecretManagerInRM clientToAMTokenSecretManager,
RMApplicationHistoryWriter rmApplicationHistoryWriter,
ResourceScheduler scheduler) |
RMNMInfo(RMContext rmc,
ResourceScheduler sched)
Constructor for RMNMInfo registers the bean with JMX.
|
Modifier and Type | Method and Description |
---|---|
static String |
AbstractReservationSystem.getDefaultReservationSystem(ResourceScheduler scheduler)
Get the default reservation system corresponding to the scheduler
|
void |
CapacitySchedulerPlanFollower.init(org.apache.hadoop.yarn.util.Clock clock,
ResourceScheduler sched,
Collection<Plan> plans) |
void |
AbstractSchedulerPlanFollower.init(org.apache.hadoop.yarn.util.Clock clock,
ResourceScheduler sched,
Collection<Plan> plans) |
void |
FairSchedulerPlanFollower.init(org.apache.hadoop.yarn.util.Clock clock,
ResourceScheduler sched,
Collection<Plan> plans) |
void |
PlanFollower.init(org.apache.hadoop.yarn.util.Clock clock,
ResourceScheduler sched,
Collection<Plan> plans)
Init function that configures the PlanFollower, by providing:
|
Modifier and Type | Interface and Description |
---|---|
interface |
PreemptableResourceScheduler
Interface for a scheduler that supports preemption/killing
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractYarnScheduler<T extends SchedulerApplicationAttempt,N extends SchedulerNode> |
Modifier and Type | Class and Description |
---|---|
class |
CapacityScheduler |
Modifier and Type | Class and Description |
---|---|
class |
FairScheduler
A scheduler that schedules resources between a set of queues.
|
Modifier and Type | Class and Description |
---|---|
class |
FifoScheduler |
Constructor and Description |
---|
QueueACLsManager(ResourceScheduler scheduler,
org.apache.hadoop.conf.Configuration conf) |
Constructor and Description |
---|
NodeInfo(RMNode ni,
ResourceScheduler sched) |
Copyright © 2015 Apache Software Foundation. All Rights Reserved.