|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerNode
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSSchedulerNode
@InterfaceAudience.Private @InterfaceStability.Unstable public class FSSchedulerNode
Constructor Summary | |
---|---|
FSSchedulerNode(RMNode node,
boolean usePortForNodeName)
|
Method Summary | |
---|---|
void |
allocateContainer(org.apache.hadoop.yarn.api.records.ApplicationId applicationId,
RMContainer rmContainer)
The Scheduler has allocated containers on this node to the given application. |
org.apache.hadoop.yarn.api.records.Resource |
getAvailableResource()
Get available resources on the node. |
String |
getHttpAddress()
|
org.apache.hadoop.yarn.api.records.NodeId |
getNodeID()
Get the ID of the node which contains both its hostname and port. |
String |
getNodeName()
Get the name of the node for scheduling matching decisions. |
int |
getNumContainers()
Get number of active containers on the node. |
String |
getRackName()
Get rackname. |
AppSchedulable |
getReservedAppSchedulable()
|
RMContainer |
getReservedContainer()
|
RMNode |
getRMNode()
|
List<RMContainer> |
getRunningContainers()
|
org.apache.hadoop.yarn.api.records.Resource |
getTotalResource()
Get total resources on the node. |
org.apache.hadoop.yarn.api.records.Resource |
getUsedResource()
Get used resources on the node. |
void |
releaseContainer(org.apache.hadoop.yarn.api.records.Container container)
Release an allocated container on this node. |
void |
reserveResource(FSSchedulerApp application,
org.apache.hadoop.yarn.api.records.Priority priority,
RMContainer reservedContainer)
|
String |
toString()
|
void |
unreserveResource(FSSchedulerApp application)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public FSSchedulerNode(RMNode node, boolean usePortForNodeName)
Method Detail |
---|
public RMNode getRMNode()
public org.apache.hadoop.yarn.api.records.NodeId getNodeID()
SchedulerNode
getNodeID
in class SchedulerNode
public String getHttpAddress()
public String getNodeName()
SchedulerNode
YarnConfiguration.RM_SCHEDULER_INCLUDE_PORT_IN_NODE_NAME
constant.
The main usecase of this is Yarn minicluster to be able to differentiate
node manager instances by their port number.
getNodeName
in class SchedulerNode
public String getRackName()
SchedulerNode
getRackName
in class SchedulerNode
public void allocateContainer(org.apache.hadoop.yarn.api.records.ApplicationId applicationId, RMContainer rmContainer)
applicationId
- applicationrmContainer
- allocated containerpublic org.apache.hadoop.yarn.api.records.Resource getAvailableResource()
SchedulerNode
getAvailableResource
in class SchedulerNode
public org.apache.hadoop.yarn.api.records.Resource getUsedResource()
SchedulerNode
getUsedResource
in class SchedulerNode
public void releaseContainer(org.apache.hadoop.yarn.api.records.Container container)
container
- container to be releasedpublic org.apache.hadoop.yarn.api.records.Resource getTotalResource()
SchedulerNode
getTotalResource
in class SchedulerNode
public String toString()
toString
in class Object
public int getNumContainers()
SchedulerNode
getNumContainers
in class SchedulerNode
public List<RMContainer> getRunningContainers()
public void reserveResource(FSSchedulerApp application, org.apache.hadoop.yarn.api.records.Priority priority, RMContainer reservedContainer)
public void unreserveResource(FSSchedulerApp application)
public RMContainer getReservedContainer()
public AppSchedulable getReservedAppSchedulable()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |