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_DECUsed to sort a list of nodes so the node with the most free slots comes first.protected Map<String,Node>NodePool. nodeIdToNodeMethods 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 booleanNodePool.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 intNode. countFreeSlotsAlive(Collection<Node> nodes)static intNode. countSlotsUsed(String topId, Collection<Node> nodes)static intNode. countSlotsUsed(Collection<Node> nodes)static intNode. countTotalSlotsAlive(Collection<Node> nodes)voidFreePool. init(Cluster cluster, Map<String,Node> nodeIdToNode)voidNodePool. init(Cluster cluster, Map<String,Node> nodeIdToNode)Initialize the pool.
-