Uses of Class
org.apache.storm.scheduler.multitenant.Node

Packages that use Node

Package	Description
org.apache.storm.scheduler.multitenant

Uses of Node in org.apache.storm.scheduler.multitenant

Fields in org.apache.storm.scheduler.multitenant with type parameters of type Node

Modifier and Type	Field and Description
protected Map<String,Node>	NodePool._nodeIdToNode
static Comparator<Node>	Node.FREE_NODE_COMPARATOR_DEC Used to sort a list of nodes so the node with the most free slots comes first.

Methods in org.apache.storm.scheduler.multitenant that return types with arguments of type Node

Modifier and Type	Method and Description
static Map<String,Node>	Node.getAllNodesFrom(Cluster cluster)
abstract Collection<Node>	NodePool.takeNodes(int nodesNeeded) Take up to nodesNeeded from this pool
Collection<Node>	IsolatedPool.takeNodes(int nodesNeeded)
Collection<Node>	FreePool.takeNodes(int nodesNeeded)
Collection<Node>	DefaultPool.takeNodes(int nodesNeeded)
static Collection<Node>	NodePool.takeNodes(int nodesNeeded, NodePool[] pools)
static Collection<Node>	NodePool.takeNodesBySlot(int slotsNeeded, NodePool[] pools)
abstract Collection<Node>	NodePool.takeNodesBySlots(int slotsNeeded) Take nodes from this pool that can fulfill possibly up to the slotsNeeded
Collection<Node>	IsolatedPool.takeNodesBySlots(int slotsNeeded)
Collection<Node>	FreePool.takeNodesBySlots(int slotsNeeded)
Collection<Node>	DefaultPool.takeNodesBySlots(int slotsNeeded)

Methods in org.apache.storm.scheduler.multitenant with parameters of type Node

Modifier and Type	Method and Description
boolean	NodePool.RoundRobinSlotScheduler.assignSlotTo(Node n) Assign a slot to the given node.

Method parameters in org.apache.storm.scheduler.multitenant with type arguments of type Node

Modifier and Type	Method and Description
static int	Node.countFreeSlotsAlive(Collection<Node> nodes)
static int	Node.countSlotsUsed(Collection<Node> nodes)
static int	Node.countSlotsUsed(String topId, Collection<Node> nodes)
static int	Node.countTotalSlotsAlive(Collection<Node> nodes)
void	NodePool.init(Cluster cluster, Map<String,Node> nodeIdToNode) Initialize the pool.
void	FreePool.init(Cluster cluster, Map<String,Node> nodeIdToNode)