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

Interface CandidateNodeSet<N extends SchedulerNode>

All Known Implementing Classes:
SimpleCandidateNodeSet
@Private @Unstable public interface CandidateNodeSet<N extends SchedulerNode>
A group of nodes which can be allocated by scheduler. It will have following part: 1) A map of nodes which can be schedule-able. 2) Version of the node set, version should be updated if any node added or removed from the node set. This will be used by AppPlacementAllocator or other class to check if it's required to invalidate local caches, etc. 3) Node partition of the candidate set.

  • Method Summary

    Modifier and Type
    Method
    Description
    Map<org.apache.hadoop.yarn.api.records.NodeId,N>
    getAllNodes()
    Get all nodes for this CandidateNodeSet
    String
    getPartition()
    Node partition of the node set.
    long
    getVersion()
    Version of the CandidateNodeSet, can help AppPlacementAllocator to decide if update is required

  • Method Details

    • getAllNodes

      Map<org.apache.hadoop.yarn.api.records.NodeId,N> getAllNodes()
      Get all nodes for this CandidateNodeSet
      Returns:
      all nodes for this CandidateNodeSet

    • getVersion

      long getVersion()
      Version of the CandidateNodeSet, can help AppPlacementAllocator to decide if update is required
      Returns:
      version

    • getPartition

      String getPartition()
      Node partition of the node set.
      Returns:
      node partition