@InterfaceAudience.Private @InterfaceStability.Unstable public class FiCaSchedulerApp extends SchedulerApplication
Constructor and Description |
---|
FiCaSchedulerApp(ApplicationAttemptId applicationAttemptId,
String user,
Queue queue,
ActiveUsersManager activeUsersManager,
RMContext rmContext) |
public FiCaSchedulerApp(ApplicationAttemptId applicationAttemptId, String user, Queue queue, ActiveUsersManager activeUsersManager, RMContext rmContext)
public ApplicationId getApplicationId()
public ApplicationAttemptId getApplicationAttemptId()
SchedulerApplication
ApplicationAttemptId
of the application master.getApplicationAttemptId
in class SchedulerApplication
ApplicationAttemptId
of the application masterpublic String getUser()
public void updateResourceRequests(List<ResourceRequest> requests)
public void updateBlacklist(List<String> blacklistAdditions, List<String> blacklistRemovals)
public Map<String,ResourceRequest> getResourceRequests(Priority priority)
public int getNewContainerId()
public Collection<Priority> getPriorities()
public ResourceRequest getResourceRequest(Priority priority, String resourceName)
public int getTotalRequiredResources(Priority priority)
public boolean isBlacklisted(String resourceName)
public boolean isPending()
isPending
in class SchedulerApplication
public boolean isStopped()
public String getQueueName()
public Collection<RMContainer> getLiveContainers()
getLiveContainers
in class SchedulerApplication
public void stop(RMAppAttemptState rmAppAttemptFinalState)
public void containerLaunchedOnNode(ContainerId containerId, NodeId nodeId)
public boolean containerCompleted(RMContainer rmContainer, ContainerStatus containerStatus, RMContainerEventType event)
public RMContainer allocate(NodeType type, FiCaSchedulerNode node, Priority priority, ResourceRequest request, Container container)
public Resource getCurrentConsumption()
public void showRequests()
public RMContainer getRMContainer(ContainerId id)
public void resetSchedulingOpportunities(Priority priority)
public void addSchedulingOpportunity(Priority priority)
public void subtractSchedulingOpportunity(Priority priority)
public int getSchedulingOpportunities(Priority priority)
priority
- Target prioritypublic int getReReservations(Priority priority)
public int getNumReservedContainers(Priority priority)
@InterfaceStability.Stable @InterfaceAudience.Private public Resource getCurrentReservation()
public RMContainer reserve(FiCaSchedulerNode node, Priority priority, RMContainer rmContainer, Container container)
public boolean unreserve(FiCaSchedulerNode node, Priority priority)
public boolean isReserved(FiCaSchedulerNode node, Priority priority)
node
at the
given priority
?node
- node to be checkedpriority
- priority of reserved containerpublic float getLocalityWaitFactor(Priority priority, int clusterNodes)
public List<RMContainer> getReservedContainers()
getReservedContainers
in class SchedulerApplication
public void setHeadroom(Resource globalLimit)
public Resource getHeadroom()
public Queue getQueue()
public Resource getTotalPendingRequests()
public void addPreemptContainer(ContainerId cont)
public Allocation getAllocation(ResourceCalculator rc, Resource clusterResource, Resource minimumAllocation)
rc
- clusterResource
- minimumAllocation
- Copyright © 2013 Apache Software Foundation. All rights reserved.