blob: fc7bafd3861ac92a149653e53f7a0d338b357bc3 [file] [log] [blame]
package org.apache.hadoop.yarn.server.resourcemanager.rmnode;
import java.util.List;
import java.util.Map;
import org.apache.hadoop.yarn.api.records.ApplicationId;
import org.apache.hadoop.yarn.api.records.Container;
import org.apache.hadoop.yarn.api.records.NodeHealthStatus;
import org.apache.hadoop.yarn.api.records.NodeId;
import org.apache.hadoop.yarn.server.api.records.HeartbeatResponse;
public class RMNodeStatusEvent extends RMNodeEvent {
private final NodeHealthStatus nodeHealthStatus;
private Map<ApplicationId, List<Container>> containersCollection;
private final HeartbeatResponse latestResponse;
public RMNodeStatusEvent(NodeId nodeId, NodeHealthStatus nodeHealthStatus,
Map<ApplicationId, List<Container>> collection,
HeartbeatResponse latestResponse) {
super(nodeId, RMNodeEventType.STATUS_UPDATE);
this.nodeHealthStatus = nodeHealthStatus;
this.containersCollection = collection;
this.latestResponse = latestResponse;
}
public NodeHealthStatus getNodeHealthStatus() {
return this.nodeHealthStatus;
}
public Map<ApplicationId, List<Container>> getContainersCollection() {
return this.containersCollection;
}
public HeartbeatResponse getLatestResponse() {
return this.latestResponse;
}
}