public class NodeCoordinator extends Object implements NodeStateListener, NodeShellListener, ClusterStateListener
| Constructor and Description |
|---|
NodeCoordinator(Cluster cluster) |
| Modifier and Type | Method and Description |
|---|---|
void |
addBottler(Bottler bottler) |
void |
execFinished(long nodeID,
Exception e,
int status) |
Set<ClusterNode> |
getAvailableNodes() |
ArrayList<Bottler> |
getBottlers() |
ClusterNode |
getNode(long id) |
Set<ClusterNode> |
getNodes() |
ArrayList<NodeParameters> |
getParameters() |
Set<ClusterNode> |
getRunningNodes() |
void |
ioStreamsReady(InputStream is,
OutputStream os) |
int |
numRunningNodes() |
int |
numWaitingNodes() |
void |
reset() |
void |
startNode(ClusterNode node) |
void |
startNode(NodeParameters params) |
void |
stateChanged(Cluster cluster) |
void |
stateChanged(ClusterNode node,
ClusterNodeState stateNow,
ClusterNodeState lastState) |
public NodeCoordinator(Cluster cluster)
public void stateChanged(ClusterNode node, ClusterNodeState stateNow, ClusterNodeState lastState)
stateChanged in interface NodeStateListenerpublic void stateChanged(Cluster cluster)
stateChanged in interface ClusterStateListenerpublic void startNode(NodeParameters params)
public void startNode(ClusterNode node)
public Set<ClusterNode> getNodes()
public Set<ClusterNode> getRunningNodes()
public Set<ClusterNode> getAvailableNodes()
public int numRunningNodes()
public int numWaitingNodes()
public void reset()
public ClusterNode getNode(long id)
public void execFinished(long nodeID,
Exception e,
int status)
execFinished in interface NodeShellListenerpublic void ioStreamsReady(InputStream is, OutputStream os)
ioStreamsReady in interface NodeShellListenerpublic void addBottler(Bottler bottler)
public ArrayList<NodeParameters> getParameters()
Copyright © 2015–2021 Fiji. All rights reserved.