Package | Description |
---|---|
org.apache.storm.scheduler | |
org.apache.storm.scheduler.resource |
Modifier and Type | Method and Description |
---|---|
SupervisorDetails |
Cluster.getSupervisorById(String nodeId)
Get a specific supervisor with the
nodeId |
Modifier and Type | Method and Description |
---|---|
Map<String,SupervisorDetails> |
Cluster.getSupervisors()
Get all the supervisors.
|
List<SupervisorDetails> |
Cluster.getSupervisorsByHost(String host)
Get all the supervisors on the specified
host . |
Modifier and Type | Method and Description |
---|---|
Set<Integer> |
Cluster.getAssignablePorts(SupervisorDetails supervisor) |
List<WorkerSlot> |
Cluster.getAssignableSlots(SupervisorDetails supervisor) |
Set<Integer> |
Cluster.getAvailablePorts(SupervisorDetails supervisor)
Return the available ports of this supervisor.
|
List<WorkerSlot> |
Cluster.getAvailableSlots(SupervisorDetails supervisor)
Return all the available slots on this supervisor.
|
Set<Integer> |
Cluster.getUsedPorts(SupervisorDetails supervisor)
Get all the used ports of this supervisor.
|
Modifier and Type | Method and Description |
---|---|
Collection<WorkerSlot> |
INimbus.allSlotsAvailableForScheduling(Collection<SupervisorDetails> existingSupervisors,
Topologies topologies,
Set<String> topologiesMissingAssignments)
Returns all slots that are available for the next round of scheduling.
|
String |
INimbus.getHostName(Map<String,SupervisorDetails> existingSupervisors,
String nodeId)
map from node id to supervisor details
|
Constructor and Description |
---|
Cluster(INimbus nimbus,
Map<String,SupervisorDetails> supervisors,
Map<String,SchedulerAssignmentImpl> assignments,
Map storm_conf) |
Constructor and Description |
---|
RAS_Node(String nodeId,
SupervisorDetails sup,
Cluster cluster,
Topologies topologies,
Map<String,WorkerSlot> workerIdToWorker,
Map<String,Map<String,Collection<ExecutorDetails>>> assignmentMap) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.