Uses of Class
org.apache.storm.scheduler.multitenant.NodePool
-
Packages that use NodePool Package Description org.apache.storm.scheduler.multitenant -
-
Uses of NodePool in org.apache.storm.scheduler.multitenant
Subclasses of NodePool in org.apache.storm.scheduler.multitenant Modifier and Type Class Description class
DefaultPool
A pool of machines that anyone can use, but topologies are not isolated.class
FreePool
All of the machines that currently have nothing assigned to them.class
IsolatedPool
A pool of machines that can be used to run isolated topologies.Methods in org.apache.storm.scheduler.multitenant with parameters of type NodePool Modifier and Type Method Description static int
NodePool. getNodeCountIfSlotsWereTaken(int slots, NodePool[] pools)
static int
NodePool. nodesAvailable(NodePool[] pools)
void
DefaultPool. scheduleAsNeeded(NodePool... lesserPools)
void
FreePool. scheduleAsNeeded(NodePool... lesserPools)
void
IsolatedPool. scheduleAsNeeded(NodePool... lesserPools)
abstract void
NodePool. scheduleAsNeeded(NodePool... lesserPools)
Reschedule any topologies as needed.static int
NodePool. slotsAvailable(NodePool[] pools)
static Collection<Node>
NodePool. takeNodes(int nodesNeeded, NodePool[] pools)
static Collection<Node>
NodePool. takeNodesBySlot(int slotsNeeded, NodePool[] pools)
-