public class SchedulerHealth extends Object
Modifier and Type | Class and Description |
---|---|
static class |
SchedulerHealth.DetailedInformation |
Constructor and Description |
---|
SchedulerHealth() |
Modifier and Type | Method and Description |
---|---|
Long |
getAggregateAllocationCount() |
Long |
getAggregateFulFilledReservationsCount() |
Long |
getAggregatePreemptionCount() |
Long |
getAggregateReleaseCount() |
Long |
getAggregateReservationCount() |
Long |
getAllocationCount() |
SchedulerHealth.DetailedInformation |
getLastAllocationDetails() |
SchedulerHealth.DetailedInformation |
getLastPreemptionDetails() |
SchedulerHealth.DetailedInformation |
getLastReleaseDetails() |
SchedulerHealth.DetailedInformation |
getLastReservationDetails() |
long |
getLastSchedulerRunTime() |
Long |
getPreemptionCount() |
Long |
getReleaseCount() |
Long |
getReservationCount() |
org.apache.hadoop.yarn.api.records.Resource |
getResourcesAllocated() |
org.apache.hadoop.yarn.api.records.Resource |
getResourcesReleased() |
org.apache.hadoop.yarn.api.records.Resource |
getResourcesReserved() |
void |
updateAllocation(long timestamp,
org.apache.hadoop.yarn.api.records.NodeId nodeId,
org.apache.hadoop.yarn.api.records.ContainerId containerId,
String queue) |
void |
updatePreemption(long timestamp,
org.apache.hadoop.yarn.api.records.NodeId nodeId,
org.apache.hadoop.yarn.api.records.ContainerId containerId,
String queue) |
void |
updateRelease(long timestamp,
org.apache.hadoop.yarn.api.records.NodeId nodeId,
org.apache.hadoop.yarn.api.records.ContainerId containerId,
String queue) |
void |
updateReservation(long timestamp,
org.apache.hadoop.yarn.api.records.NodeId nodeId,
org.apache.hadoop.yarn.api.records.ContainerId containerId,
String queue) |
void |
updateSchedulerAllocationCounts(long count) |
void |
updateSchedulerFulfilledReservationCounts(long count) |
void |
updateSchedulerPreemptionCounts(long count) |
void |
updateSchedulerReleaseCounts(long count) |
void |
updateSchedulerReleaseDetails(long timestamp,
org.apache.hadoop.yarn.api.records.Resource released) |
void |
updateSchedulerReservationCounts(long count) |
void |
updateSchedulerRunDetails(long timestamp,
org.apache.hadoop.yarn.api.records.Resource allocated,
org.apache.hadoop.yarn.api.records.Resource reserved) |
public void updateAllocation(long timestamp, org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.api.records.ContainerId containerId, String queue)
public void updateRelease(long timestamp, org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.api.records.ContainerId containerId, String queue)
public void updatePreemption(long timestamp, org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.api.records.ContainerId containerId, String queue)
public void updateReservation(long timestamp, org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.api.records.ContainerId containerId, String queue)
public void updateSchedulerRunDetails(long timestamp, org.apache.hadoop.yarn.api.records.Resource allocated, org.apache.hadoop.yarn.api.records.Resource reserved)
public void updateSchedulerReleaseDetails(long timestamp, org.apache.hadoop.yarn.api.records.Resource released)
public void updateSchedulerReleaseCounts(long count)
public void updateSchedulerAllocationCounts(long count)
public void updateSchedulerReservationCounts(long count)
public void updateSchedulerFulfilledReservationCounts(long count)
public void updateSchedulerPreemptionCounts(long count)
public long getLastSchedulerRunTime()
public org.apache.hadoop.yarn.api.records.Resource getResourcesAllocated()
public org.apache.hadoop.yarn.api.records.Resource getResourcesReserved()
public org.apache.hadoop.yarn.api.records.Resource getResourcesReleased()
public SchedulerHealth.DetailedInformation getLastAllocationDetails()
public SchedulerHealth.DetailedInformation getLastReleaseDetails()
public SchedulerHealth.DetailedInformation getLastReservationDetails()
public SchedulerHealth.DetailedInformation getLastPreemptionDetails()
public Long getAllocationCount()
public Long getReleaseCount()
public Long getReservationCount()
public Long getPreemptionCount()
public Long getAggregateAllocationCount()
public Long getAggregateReleaseCount()
public Long getAggregateReservationCount()
public Long getAggregatePreemptionCount()
public Long getAggregateFulFilledReservationsCount()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.