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

Class ClusterNode

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.distributed.ClusterNode

public class ClusterNode
extends Object

Represents a node in the cluster from the NodeQueueLoadMonitor's perspective

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ClusterNode.Properties	Properties class used to initialize/change fields in ClusterNode.

Constructor Summary

Constructors

Constructor	Description
ClusterNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)

Method Summary

Modifier and Type	Method	Description
boolean	compareAndIncrementAllocation(int incrementQLen)
boolean	compareAndIncrementAllocation(int incrementQLen, org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator, org.apache.hadoop.yarn.api.records.Resource requested)
org.apache.hadoop.yarn.api.records.Resource	getAllocatedResource()
org.apache.hadoop.yarn.api.records.Resource	getAvailableResource()
org.apache.hadoop.yarn.api.records.Resource	getCapability()
int	getQueueCapacity()
int	getQueueLength()
int	getQueueWaitTime()
long	getTimestamp()
boolean	hasLabel(String label)
boolean	isQueueFull()
ClusterNode	setProperties(ClusterNode.Properties properties)

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterNode

public ClusterNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)

Method Details

setProperties

public ClusterNode setProperties(ClusterNode.Properties properties)

getAllocatedResource

public org.apache.hadoop.yarn.api.records.Resource getAllocatedResource()

getAvailableResource

public org.apache.hadoop.yarn.api.records.Resource getAvailableResource()

getCapability

public org.apache.hadoop.yarn.api.records.Resource getCapability()

hasLabel

public boolean hasLabel(String label)

getTimestamp

public long getTimestamp()

getQueueLength

public int getQueueLength()

getQueueWaitTime

public int getQueueWaitTime()

getQueueCapacity

public int getQueueCapacity()

compareAndIncrementAllocation

public boolean compareAndIncrementAllocation(int incrementQLen,
 org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator,
 org.apache.hadoop.yarn.api.records.Resource requested)

compareAndIncrementAllocation

public boolean compareAndIncrementAllocation(int incrementQLen)

isQueueFull

public boolean isQueueFull()