public class RMNodeStatusEvent extends RMNodeEvent
Constructor and Description |
---|
RMNodeStatusEvent(org.apache.hadoop.yarn.api.records.NodeId nodeId,
org.apache.hadoop.yarn.server.api.records.NodeStatus nodeStatus,
org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse latestResponse) |
RMNodeStatusEvent(org.apache.hadoop.yarn.api.records.NodeId nodeId,
org.apache.hadoop.yarn.server.api.records.NodeStatus nodeStatus,
org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse latestResponse,
List<org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport> logAggregationReportsForApps) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.api.records.ResourceUtilization |
getAggregatedContainersUtilization() |
List<org.apache.hadoop.yarn.api.records.ContainerStatus> |
getContainers() |
List<org.apache.hadoop.yarn.api.records.ApplicationId> |
getKeepAliveAppIds() |
org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse |
getLatestResponse() |
List<org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport> |
getLogAggregationReportsForApps() |
List<org.apache.hadoop.yarn.api.records.Container> |
getNMReportedIncreasedContainers() |
org.apache.hadoop.yarn.server.api.records.NodeHealthStatus |
getNodeHealthStatus() |
org.apache.hadoop.yarn.api.records.ResourceUtilization |
getNodeUtilization() |
void |
setLogAggregationReportsForApps(List<org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport> logAggregationReportsForApps) |
getNodeId
public RMNodeStatusEvent(org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.server.api.records.NodeStatus nodeStatus, org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse latestResponse)
public RMNodeStatusEvent(org.apache.hadoop.yarn.api.records.NodeId nodeId, org.apache.hadoop.yarn.server.api.records.NodeStatus nodeStatus, org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse latestResponse, List<org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport> logAggregationReportsForApps)
public org.apache.hadoop.yarn.server.api.records.NodeHealthStatus getNodeHealthStatus()
public List<org.apache.hadoop.yarn.api.records.ContainerStatus> getContainers()
public org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse getLatestResponse()
public List<org.apache.hadoop.yarn.api.records.ApplicationId> getKeepAliveAppIds()
public org.apache.hadoop.yarn.api.records.ResourceUtilization getAggregatedContainersUtilization()
public org.apache.hadoop.yarn.api.records.ResourceUtilization getNodeUtilization()
public List<org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport> getLogAggregationReportsForApps()
public void setLogAggregationReportsForApps(List<org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport> logAggregationReportsForApps)
public List<org.apache.hadoop.yarn.api.records.Container> getNMReportedIncreasedContainers()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.