backtype.storm.scheduler.multitenant

Class IsolatedPool

java.lang.Object

backtype.storm.scheduler.multitenant.NodePool

backtype.storm.scheduler.multitenant.IsolatedPool

public class IsolatedPool
extends NodePool

A pool of machines that can be used to run isolated topologies

Nested Class Summary

Nested classes/interfaces inherited from class backtype.storm.scheduler.multitenant.NodePool

NodePool.NodeAndSlotCounts, NodePool.RoundRobinSlotScheduler

Field Summary

Fields inherited from class backtype.storm.scheduler.multitenant.NodePool

_cluster, _nodeIdToNode

Constructor Summary

Constructors

Constructor and Description
IsolatedPool(int maxNodes)

Method Summary

Methods

Modifier and Type	Method and Description
void	addTopology(TopologyDetails td) Add a topology to the pool
boolean	canAdd(TopologyDetails td) Check if this topology can be added to this pool
NodePool.NodeAndSlotCounts	getNodeAndSlotCountIfSlotsWereTaken(int slotsNeeded) Get the number of nodes and slots this would provide to get the slots needed
int	nodesAvailable()
void	scheduleAsNeeded(NodePool... lesserPools) Reschedule any topologies as needed.
int	slotsAvailable()
Collection<Node>	takeNodes(int nodesNeeded) Take up to nodesNeeded from this pool
Collection<Node>	takeNodesBySlots(int slotsNeeded) Take nodes from this pool that can fulfill possibly up to the slotsNeeded
String	toString()

Methods inherited from class backtype.storm.scheduler.multitenant.NodePool

getNodeCountIfSlotsWereTaken, init, nodesAvailable, slotsAvailable, takeNodes, takeNodesBySlot

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

IsolatedPool

public IsolatedPool(int maxNodes)

Method Detail

addTopology

public void addTopology(TopologyDetails td)

Description copied from class: NodePool

Add a topology to the pool

Specified by:

addTopology in class NodePool

Parameters:

td - the topology to add.

canAdd

public boolean canAdd(TopologyDetails td)

Description copied from class: NodePool

Check if this topology can be added to this pool

Specified by:

canAdd in class NodePool

Parameters:

td - the topology

Returns:

true if it can else false

scheduleAsNeeded

public void scheduleAsNeeded(NodePool... lesserPools)

Description copied from class: NodePool

Reschedule any topologies as needed.

Specified by:

scheduleAsNeeded in class NodePool

Parameters:

lesserPools - pools that may be used to steal nodes from.

takeNodes

public Collection<Node> takeNodes(int nodesNeeded)

Description copied from class: NodePool

Take up to nodesNeeded from this pool

Specified by:

takeNodes in class NodePool

Parameters:

nodesNeeded - the number of nodes that are needed.

Returns:

a Collection of nodes with the removed nodes in it. This may be empty, but should not be null.

nodesAvailable

public int nodesAvailable()

Specified by:

nodesAvailable in class NodePool

Returns:

the number of nodes that are available to be taken

slotsAvailable

public int slotsAvailable()

Specified by:

slotsAvailable in class NodePool

Returns:

the number of nodes that are available to be taken

takeNodesBySlots

public Collection<Node> takeNodesBySlots(int slotsNeeded)

Description copied from class: NodePool

Take nodes from this pool that can fulfill possibly up to the slotsNeeded

Specified by:

takeNodesBySlots in class NodePool

Parameters:

slotsNeeded - the number of slots that are needed.

Returns:

a Collection of nodes with the removed nodes in it. This may be empty, but should not be null.

getNodeAndSlotCountIfSlotsWereTaken

public NodePool.NodeAndSlotCounts getNodeAndSlotCountIfSlotsWereTaken(int slotsNeeded)

Description copied from class: NodePool

Get the number of nodes and slots this would provide to get the slots needed

Specified by:

getNodeAndSlotCountIfSlotsWereTaken in class NodePool

Parameters:

slotsNeeded - the number of slots needed

Returns:

the number of nodes and slots that would be returned.

toString

public String toString()

Overrides:

toString in class Object