| package edu.uci.ics.hyracks.control.cc; |
| |
| import java.util.HashSet; |
| import java.util.Set; |
| import java.util.UUID; |
| |
| import edu.uci.ics.hyracks.api.control.INodeController; |
| |
| public class NodeControllerState { |
| private final INodeController nodeController; |
| |
| private final Set<UUID> activeJobIds; |
| |
| private int lastHeartbeatDuration; |
| |
| public NodeControllerState(INodeController nodeController) { |
| this.nodeController = nodeController; |
| activeJobIds = new HashSet<UUID>(); |
| } |
| |
| public void notifyHeartbeat() { |
| lastHeartbeatDuration = 0; |
| } |
| |
| public int incrementLastHeartbeatDuration() { |
| return lastHeartbeatDuration++; |
| } |
| |
| public int getLastHeartbeatDuration() { |
| return lastHeartbeatDuration; |
| } |
| |
| public INodeController getNodeController() { |
| return nodeController; |
| } |
| |
| public Set<UUID> getActiveJobIds() { |
| return activeJobIds; |
| } |
| } |