public class PreemptionManager extends Object
Constructor and Description |
---|
PreemptionManager() |
Modifier and Type | Method and Description |
---|---|
void |
addKillableContainer(KillableContainer container) |
Iterator<RMContainer> |
getKillableContainers(String queueName,
String partition) |
Map<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer> |
getKillableContainersMap(String queueName,
String partition) |
org.apache.hadoop.yarn.api.records.Resource |
getKillableResource(String queueName,
String partition) |
Map<String,PreemptableQueue> |
getShallowCopyOfPreemptableQueues() |
void |
moveKillableContainer(KillableContainer oldContainer,
KillableContainer newContainer) |
void |
refreshQueues(CSQueue parent,
CSQueue current) |
void |
removeKillableContainer(KillableContainer container) |
void |
updateKillableContainerResource(KillableContainer container,
org.apache.hadoop.yarn.api.records.Resource oldResource,
org.apache.hadoop.yarn.api.records.Resource newResource) |
public void addKillableContainer(KillableContainer container)
public void removeKillableContainer(KillableContainer container)
public void moveKillableContainer(KillableContainer oldContainer, KillableContainer newContainer)
public void updateKillableContainerResource(KillableContainer container, org.apache.hadoop.yarn.api.records.Resource oldResource, org.apache.hadoop.yarn.api.records.Resource newResource)
public Map<org.apache.hadoop.yarn.api.records.ContainerId,RMContainer> getKillableContainersMap(String queueName, String partition)
public Iterator<RMContainer> getKillableContainers(String queueName, String partition)
public org.apache.hadoop.yarn.api.records.Resource getKillableResource(String queueName, String partition)
public Map<String,PreemptableQueue> getShallowCopyOfPreemptableQueues()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.