Package | Description |
---|---|
org.apache.storm.scheduler.multitenant |
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 |
Modifier and Type | Method and Description |
---|---|
static Map<String,Node> |
Node.getAllNodesFrom(Cluster cluster) |
Collection<Node> |
FreePool.takeNodes(int nodesNeeded) |
Collection<Node> |
DefaultPool.takeNodes(int nodesNeeded) |
abstract Collection<Node> |
NodePool.takeNodes(int nodesNeeded)
Take up to nodesNeeded from this pool.
|
Collection<Node> |
IsolatedPool.takeNodes(int nodesNeeded) |
static Collection<Node> |
NodePool.takeNodes(int nodesNeeded,
NodePool[] pools) |
static Collection<Node> |
NodePool.takeNodesBySlot(int slotsNeeded,
NodePool[] pools) |
Collection<Node> |
FreePool.takeNodesBySlots(int slotsNeeded) |
Collection<Node> |
DefaultPool.takeNodesBySlots(int slotsNeeded) |
abstract Collection<Node> |
NodePool.takeNodesBySlots(int slotsNeeded)
Take nodes from this pool that can fulfill possibly up to the slotsNeeded.
|
Collection<Node> |
IsolatedPool.takeNodesBySlots(int slotsNeeded) |
Modifier and Type | Method and Description |
---|---|
boolean |
NodePool.RoundRobinSlotScheduler.assignSlotTo(Node n)
Assign a slot to the given 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.
|
Copyright © 2020 The Apache Software Foundation. All rights reserved.