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

Class SimpleCandidateNodeSet<N extends SchedulerNode>

java.lang.Object

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

All Implemented Interfaces:

CandidateNodeSet<N>

public class SimpleCandidateNodeSet<N extends SchedulerNode>
extends Object
implements CandidateNodeSet<N>

A simple CandidateNodeSet which keeps an unordered map

Constructor Summary

Constructors

Constructor	Description
SimpleCandidateNodeSet(Map<org.apache.hadoop.yarn.api.records.NodeId,N> map, String partition)
SimpleCandidateNodeSet(N node)

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

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleCandidateNodeSet

public SimpleCandidateNodeSet(N node)

SimpleCandidateNodeSet

public SimpleCandidateNodeSet(Map<org.apache.hadoop.yarn.api.records.NodeId,N> map,
 String partition)

Method Details

getAllNodes

public Map<org.apache.hadoop.yarn.api.records.NodeId,N> getAllNodes()

Description copied from interface: CandidateNodeSet

Get all nodes for this CandidateNodeSet

Specified by:

getAllNodes in interface CandidateNodeSet<N extends SchedulerNode>

Returns:

all nodes for this CandidateNodeSet

getVersion

public long getVersion()

Description copied from interface: CandidateNodeSet

Version of the CandidateNodeSet, can help AppPlacementAllocator to decide if update is required

Specified by:

getVersion in interface CandidateNodeSet<N extends SchedulerNode>

Returns:

version

getPartition

public String getPartition()

Description copied from interface: CandidateNodeSet

Node partition of the node set.

Specified by:

getPartition in interface CandidateNodeSet<N extends SchedulerNode>

Returns:

node partition