Modifier and Type | Class and Description |
---|---|
class |
RMContainerImpl |
Modifier and Type | Method and Description |
---|---|
RMContainer |
ContainerPreemptEvent.getContainer() |
Modifier and Type | Method and Description |
---|---|
Collection<RMContainer> |
SchedulerAppReport.getLiveContainers()
Get the list of live containers
|
abstract Collection<RMContainer> |
SchedulerApplication.getLiveContainers()
Get the live containers of the application.
|
Collection<RMContainer> |
SchedulerAppReport.getReservedContainers()
Get the list of reserved containers
|
abstract Collection<RMContainer> |
SchedulerApplication.getReservedContainers()
Get the reserved containers of the application.
|
Modifier and Type | Method and Description |
---|---|
void |
PreemptableResourceScheduler.dropContainerReservation(RMContainer container)
If the scheduler support container reservations, this method is used to
ask the scheduler to drop the reservation for the given container.
|
void |
PreemptableResourceScheduler.killContainer(RMContainer container)
Ask the scheduler to forcibly interrupt the container given as input
|
void |
PreemptableResourceScheduler.preemptContainer(ApplicationAttemptId aid,
RMContainer container)
Ask the scheduler to obtain back the container from a specific application
by issuing a preemption request
|
Constructor and Description |
---|
ContainerPreemptEvent(ApplicationAttemptId aid,
RMContainer container,
ContainerPreemptEventType type) |
Modifier and Type | Method and Description |
---|---|
RMContainer |
CSAssignment.getExcessReservation() |
Modifier and Type | Method and Description |
---|---|
void |
ParentQueue.completedContainer(Resource clusterResource,
FiCaSchedulerApp application,
FiCaSchedulerNode node,
RMContainer rmContainer,
ContainerStatus containerStatus,
RMContainerEventType event,
CSQueue completedChildQueue) |
void |
CSQueue.completedContainer(Resource clusterResource,
FiCaSchedulerApp application,
FiCaSchedulerNode node,
RMContainer container,
ContainerStatus containerStatus,
RMContainerEventType event,
CSQueue childQueue)
A container assigned to the queue has completed.
|
void |
LeafQueue.completedContainer(Resource clusterResource,
FiCaSchedulerApp application,
FiCaSchedulerNode node,
RMContainer rmContainer,
ContainerStatus containerStatus,
RMContainerEventType event,
CSQueue childQueue) |
void |
CapacityScheduler.dropContainerReservation(RMContainer container) |
void |
CapacityScheduler.killContainer(RMContainer cont) |
void |
CapacityScheduler.preemptContainer(ApplicationAttemptId aid,
RMContainer cont) |
Constructor and Description |
---|
CSAssignment(FiCaSchedulerApp application,
RMContainer excessReservation) |
Modifier and Type | Method and Description |
---|---|
RMContainer |
FiCaSchedulerApp.allocate(NodeType type,
FiCaSchedulerNode node,
Priority priority,
ResourceRequest request,
Container container) |
RMContainer |
FiCaSchedulerNode.getReservedContainer() |
RMContainer |
FiCaSchedulerApp.getRMContainer(ContainerId id) |
RMContainer |
FiCaSchedulerApp.reserve(FiCaSchedulerNode node,
Priority priority,
RMContainer rmContainer,
Container container) |
Modifier and Type | Method and Description |
---|---|
Collection<RMContainer> |
FiCaSchedulerApp.getLiveContainers()
Get the list of live containers
|
List<RMContainer> |
FiCaSchedulerApp.getReservedContainers()
Get the list of reserved containers
|
List<RMContainer> |
FiCaSchedulerNode.getRunningContainers() |
Modifier and Type | Method and Description |
---|---|
void |
FiCaSchedulerNode.allocateContainer(ApplicationId applicationId,
RMContainer rmContainer)
The Scheduler has allocated containers on this node to the
given application.
|
boolean |
FiCaSchedulerApp.containerCompleted(RMContainer rmContainer,
ContainerStatus containerStatus,
RMContainerEventType event) |
RMContainer |
FiCaSchedulerApp.reserve(FiCaSchedulerNode node,
Priority priority,
RMContainer rmContainer,
Container container) |
void |
FiCaSchedulerNode.reserveResource(SchedulerApplication application,
Priority priority,
RMContainer reservedContainer) |
Modifier and Type | Method and Description |
---|---|
RMContainer |
FSSchedulerApp.allocate(NodeType type,
FSSchedulerNode node,
Priority priority,
ResourceRequest request,
Container container) |
RMContainer |
FSSchedulerNode.getReservedContainer() |
RMContainer |
FSSchedulerApp.getRMContainer(ContainerId id) |
RMContainer |
FSSchedulerApp.reserve(FSSchedulerNode node,
Priority priority,
RMContainer rmContainer,
Container container) |
Modifier and Type | Method and Description |
---|---|
Collection<RMContainer> |
FSSchedulerApp.getLiveContainers()
Get the list of live containers
|
Set<RMContainer> |
FSSchedulerApp.getPreemptionContainers() |
List<RMContainer> |
FSSchedulerApp.getReservedContainers()
Get the list of reserved containers
|
List<RMContainer> |
FSSchedulerNode.getRunningContainers() |
Modifier and Type | Method and Description |
---|---|
void |
FSSchedulerApp.addPreemption(RMContainer container,
long time) |
void |
FSSchedulerNode.allocateContainer(ApplicationId applicationId,
RMContainer rmContainer)
The Scheduler has allocated containers on this node to the
given application.
|
void |
FSSchedulerApp.containerCompleted(RMContainer rmContainer,
ContainerStatus containerStatus,
RMContainerEventType event) |
Long |
FSSchedulerApp.getContainerPreemptionTime(RMContainer container) |
RMContainer |
FSSchedulerApp.reserve(FSSchedulerNode node,
Priority priority,
RMContainer rmContainer,
Container container) |
void |
FSSchedulerNode.reserveResource(FSSchedulerApp application,
Priority priority,
RMContainer reservedContainer) |
Copyright © 2013 Apache Software Foundation. All rights reserved.