| Package | Description |
|---|---|
| backtype.storm.scheduler | |
| backtype.storm.scheduler.multitenant |
| Modifier and Type | Method and Description |
|---|---|
void |
IScheduler.schedule(Topologies topologies,
Cluster cluster)
Set assignments for the topologies which needs scheduling.
|
| Modifier and Type | Field and Description |
|---|---|
protected Cluster |
NodePool._cluster |
| Modifier and Type | Method and Description |
|---|---|
void |
Node.assign(String topId,
Collection<ExecutorDetails> executors,
Cluster cluster)
Assign a free slot on the node to the following topology and executors.
|
void |
Node.free(WorkerSlot ws,
Cluster cluster,
boolean forceFree)
Frees a single slot in this node
|
void |
Node.freeAllSlots(Cluster cluster)
Free all slots on this node.
|
void |
Node.freeTopology(String topId,
Cluster cluster)
Frees all the slots for a topology.
|
static Map<String,Node> |
Node.getAllNodesFrom(Cluster cluster) |
void |
FreePool.init(Cluster cluster,
Map<String,Node> nodeIdToNode) |
void |
NodePool.init(Cluster cluster,
Map<String,Node> nodeIdToNode)
Initialize the pool.
|
void |
MultitenantScheduler.schedule(Topologies topologies,
Cluster cluster) |
| Constructor and Description |
|---|
NodePool.RoundRobinSlotScheduler(TopologyDetails td,
int slotsToUse,
Cluster cluster)
Create a new scheduler for a given topology
|
Copyright © 2015. All rights reserved.