Package | Description |
---|---|
org.apache.storm.scheduler.multitenant |
Modifier and Type | Class and 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
|
Modifier and Type | Method and Description |
---|---|
static int |
NodePool.getNodeCountIfSlotsWereTaken(int slots,
NodePool[] pools) |
static int |
NodePool.nodesAvailable(NodePool[] pools) |
abstract void |
NodePool.scheduleAsNeeded(NodePool... lesserPools)
Reschedule any topologies as needed.
|
void |
IsolatedPool.scheduleAsNeeded(NodePool... lesserPools) |
void |
FreePool.scheduleAsNeeded(NodePool... lesserPools) |
void |
DefaultPool.scheduleAsNeeded(NodePool... lesserPools) |
static int |
NodePool.slotsAvailable(NodePool[] pools) |
static Collection<Node> |
NodePool.takeNodes(int nodesNeeded,
NodePool[] pools) |
static Collection<Node> |
NodePool.takeNodesBySlot(int slotsNeeded,
NodePool[] pools) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.