Package org.apache.hadoop.yarn.server.resourcemanager.scheduler

Class SchedulerHealth

java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerHealth
public class SchedulerHealth extends Object
SchedulerHealth class holds the details of the schedulers operations.

SchedulerHealth provides clients with information such as:

  1. scheduler's latest timestamp
  2. resources allocated, reserved, released in the last scheduler run
  3. latest allocation, release, reservation, preemption details
  4. count of latest allocation, release, reservation, preemption
  5. aggregate count of latest allocation, release, reservation, preemption, fulfilled reservation

  • Method Details

    • updateAllocation

      public void updateAllocation(long timestamp, org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.api.records.ContainerId containerId, String queue)

    • updateRelease

      public void updateRelease(long timestamp, org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.api.records.ContainerId containerId, String queue)

    • updatePreemption

      public void updatePreemption(long timestamp, org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.api.records.ContainerId containerId, String queue)

    • updateReservation

      public void updateReservation(long timestamp, org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.api.records.ContainerId containerId, String queue)

    • updateSchedulerRunDetails

      public void updateSchedulerRunDetails(long timestamp, org.apache.hadoop.yarn.api.records.Resource allocated, org.apache.hadoop.yarn.api.records.Resource reserved)

    • updateSchedulerReleaseDetails

      public void updateSchedulerReleaseDetails(long timestamp, org.apache.hadoop.yarn.api.records.Resource released)

    • updateSchedulerReleaseCounts

      public void updateSchedulerReleaseCounts(long count)

    • updateSchedulerAllocationCounts

      public void updateSchedulerAllocationCounts(long count)

    • updateSchedulerReservationCounts

      public void updateSchedulerReservationCounts(long count)

    • updateSchedulerFulfilledReservationCounts

      public void updateSchedulerFulfilledReservationCounts(long count)

    • updateSchedulerPreemptionCounts

      public void updateSchedulerPreemptionCounts(long count)

    • getLastSchedulerRunTime

      public long getLastSchedulerRunTime()
      Get the timestamp of the latest scheduler operation.
      Returns:
      the scheduler's latest timestamp

    • getResourcesAllocated

      public org.apache.hadoop.yarn.api.records.Resource getResourcesAllocated()
      Get the resources allocated in the last scheduler run.
      Returns:
      resources allocated

    • getResourcesReserved

      public org.apache.hadoop.yarn.api.records.Resource getResourcesReserved()
      Get the resources reserved in the last scheduler run.
      Returns:
      resources reserved

    • getResourcesReleased

      public org.apache.hadoop.yarn.api.records.Resource getResourcesReleased()
      Get the resources released in the last scheduler run.
      Returns:
      resources released

    • getLastAllocationDetails

      public SchedulerHealth.DetailedInformation getLastAllocationDetails()
      Get the details of last allocation.
      Returns:
      last allocation details

    • getLastReleaseDetails

      public SchedulerHealth.DetailedInformation getLastReleaseDetails()
      Get the details of last release.
      Returns:
      last release details

    • getLastReservationDetails

      public SchedulerHealth.DetailedInformation getLastReservationDetails()
      Get the details of last reservation.
      Returns:
      last reservation details

    • getLastPreemptionDetails

      public SchedulerHealth.DetailedInformation getLastPreemptionDetails()
      Get the details of last preemption.
      Returns:
      last preemption details

    • getAllocationCount

      public Long getAllocationCount()
      Get the count of allocation from the latest scheduler health report.
      Returns:
      allocation count

    • getReleaseCount

      public Long getReleaseCount()
      Get the count of release from the latest scheduler health report.
      Returns:
      release count

    • getReservationCount

      public Long getReservationCount()
      Get the count of reservation from the latest scheduler health report.
      Returns:
      reservation count

    • getPreemptionCount

      public Long getPreemptionCount()
      Get the count of preemption from the latest scheduler health report.
      Returns:
      preemption count

    • getAggregateAllocationCount

      public Long getAggregateAllocationCount()
      Get the aggregate of all the allocations count.
      Returns:
      aggregate allocation count

    • getAggregateReleaseCount

      public Long getAggregateReleaseCount()
      Get the aggregate of all the release count.
      Returns:
      aggregate release count

    • getAggregateReservationCount

      public Long getAggregateReservationCount()
      Get the aggregate of all the reservations count.
      Returns:
      aggregate reservation count

    • getAggregatePreemptionCount

      public Long getAggregatePreemptionCount()
      Get the aggregate of all the preemption count.
      Returns:
      aggregate preemption count

    • getAggregateFulFilledReservationsCount

      public Long getAggregateFulFilledReservationsCount()
      Get the aggregate of all the fulfilled reservations count.
      Returns:
      aggregate fulfilled reservations count