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

Class ResourceUsageMultiNodeLookupPolicy<N extends SchedulerNode>

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.placement.ResourceUsageMultiNodeLookupPolicy<N>

All Implemented Interfaces:

MultiNodeLookupPolicy<N>

public class ResourceUsageMultiNodeLookupPolicy<N extends SchedulerNode>
extends Object
implements MultiNodeLookupPolicy<N>

This class has the following functionality:

ResourceUsageMultiNodeLookupPolicy holds sorted nodes list based on the resource usage of nodes at given time.

Field Summary

Fields

Modifier and Type	Field	Description
protected Comparator<N>	comparator
protected Map<String,Set<N>>	nodesPerPartition

Constructor Summary

Constructors

Constructor	Description
ResourceUsageMultiNodeLookupPolicy()

Method Summary

Modifier and Type	Method	Description
void	addAndRefreshNodesSet(Collection<N> nodes, String partition)	Refresh working nodes set for re-ordering based on the algorithm selected.
Set<N>	getNodesPerPartition(String partition)	Get sorted nodes per partition.
Iterator<N>	getPreferredNodeIterator(Collection<N> nodes, String partition)	Get iterator of preferred node depends on requirement and/or availability.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

nodesPerPartition

protected Map<String,Set<N extends SchedulerNode>> nodesPerPartition

comparator

protected Comparator<N extends SchedulerNode> comparator

Constructor Details

ResourceUsageMultiNodeLookupPolicy

public ResourceUsageMultiNodeLookupPolicy()

Method Details

getPreferredNodeIterator

public Iterator<N> getPreferredNodeIterator(Collection<N> nodes,
 String partition)

Description copied from interface: MultiNodeLookupPolicy

Get iterator of preferred node depends on requirement and/or availability.

Specified by:

getPreferredNodeIterator in interface MultiNodeLookupPolicy<N extends SchedulerNode>

Parameters:

nodes - List of Nodes

partition - node label

Returns:

iterator of preferred node

addAndRefreshNodesSet

public void addAndRefreshNodesSet(Collection<N> nodes,
 String partition)

Description copied from interface: MultiNodeLookupPolicy

Refresh working nodes set for re-ordering based on the algorithm selected.

Specified by:

addAndRefreshNodesSet in interface MultiNodeLookupPolicy<N extends SchedulerNode>

Parameters:

nodes - a collection working nm's.

partition - node label

getNodesPerPartition

public Set<N> getNodesPerPartition(String partition)

Description copied from interface: MultiNodeLookupPolicy

Get sorted nodes per partition.

Specified by:

getNodesPerPartition in interface MultiNodeLookupPolicy<N extends SchedulerNode>

Parameters:

partition - node label

Returns:

collection of sorted nodes