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
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.
protected Map<String,Node>	NodePool.nodeIdToNode

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)
Collection<Node>	DefaultPool.takeNodes(int nodesNeeded)
Collection<Node>	FreePool.takeNodes(int nodesNeeded)
Collection<Node>	IsolatedPool.takeNodes(int nodesNeeded)
abstract Collection<Node>	NodePool.takeNodes(int nodesNeeded) Take up to nodesNeeded from this pool.
static Collection<Node>	NodePool.takeNodes(int nodesNeeded, NodePool[] pools)
static Collection<Node>	NodePool.takeNodesBySlot(int slotsNeeded, NodePool[] pools)
Collection<Node>	DefaultPool.takeNodesBySlots(int slotsNeeded)
Collection<Node>	FreePool.takeNodesBySlots(int slotsNeeded)
Collection<Node>	IsolatedPool.takeNodesBySlots(int slotsNeeded)
abstract Collection<Node>	NodePool.takeNodesBySlots(int slotsNeeded) Take nodes from this pool that can fulfill possibly up to the 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	FreePool.init(Cluster cluster, Map<String,Node> nodeIdToNode)
void	NodePool.init(Cluster cluster, Map<String,Node> nodeIdToNode) Initialize the pool.