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

Interface MultiNodeLookupPolicy<N extends SchedulerNode>

All Known Implementing Classes:
ResourceUsageMultiNodeLookupPolicy
public interface MultiNodeLookupPolicy<N extends SchedulerNode>

This class has the following functionality.

Provide an interface for MultiNodeLookupPolicy so that different placement allocator can choose nodes based on need.

  • Method Details

    • getPreferredNodeIterator

      Iterator<N> getPreferredNodeIterator(Collection<N> nodes, String partition)
      Get iterator of preferred node depends on requirement and/or availability.
      Parameters:
      nodes - List of Nodes
      partition - node label
      Returns:
      iterator of preferred node

    • addAndRefreshNodesSet

      void addAndRefreshNodesSet(Collection<N> nodes, String partition)
      Refresh working nodes set for re-ordering based on the algorithm selected.
      Parameters:
      nodes - a collection working nm's.
      partition - node label

    • getNodesPerPartition

      Set<N> getNodesPerPartition(String partition)
      Get sorted nodes per partition.
      Parameters:
      partition - node label
      Returns:
      collection of sorted nodes