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 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 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 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 Description static int
Node. countFreeSlotsAlive(Collection<Node> nodes)
static int
Node. countSlotsUsed(String topId, Collection<Node> nodes)
static int
Node. countSlotsUsed(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.
-