Uses of Class
org.apache.storm.scheduler.SupervisorDetails
-
Packages that use SupervisorDetails Package Description org.apache.storm.daemon.nimbus org.apache.storm.scheduler org.apache.storm.scheduler.resource -
-
Uses of SupervisorDetails in org.apache.storm.daemon.nimbus
Method parameters in org.apache.storm.daemon.nimbus with type arguments of type SupervisorDetails Modifier and Type Method Description Collection<WorkerSlot>
Nimbus.StandaloneINimbus. allSlotsAvailableForScheduling(Collection<SupervisorDetails> supervisors, Topologies topologies, Set<String> topologiesMissingAssignments)
String
Nimbus.StandaloneINimbus. getHostName(Map<String,SupervisorDetails> supervisors, String nodeId)
-
Uses of SupervisorDetails in org.apache.storm.scheduler
Methods in org.apache.storm.scheduler that return SupervisorDetails Modifier and Type Method Description SupervisorDetails
Cluster. getSupervisorById(String nodeId)
SupervisorDetails
ISchedulingState. getSupervisorById(String nodeId)
Get a specific supervisor with thenodeId
.Methods in org.apache.storm.scheduler that return types with arguments of type SupervisorDetails Modifier and Type Method Description Map<String,SupervisorDetails>
Cluster. getSupervisors()
Map<String,SupervisorDetails>
ISchedulingState. getSupervisors()
Get all the supervisors.List<SupervisorDetails>
Cluster. getSupervisorsByHost(String host)
List<SupervisorDetails>
ISchedulingState. getSupervisorsByHost(String host)
Get all the supervisors on the specifiedhost
.Methods in org.apache.storm.scheduler with parameters of type SupervisorDetails Modifier and Type Method Description Set<Integer>
Cluster. getAssignablePorts(SupervisorDetails supervisor)
Set<Integer>
ISchedulingState. getAssignablePorts(SupervisorDetails supervisor)
Get the ports that are not blacklisted.List<WorkerSlot>
Cluster. getAssignableSlots(SupervisorDetails supervisor)
List<WorkerSlot>
ISchedulingState. getAssignableSlots(SupervisorDetails supervisor)
Return all non-blacklisted slots on this supervisor.Set<Integer>
Cluster. getAvailablePorts(SupervisorDetails supervisor)
Set<Integer>
ISchedulingState. getAvailablePorts(SupervisorDetails supervisor)
Return the available ports of this supervisor.NormalizedResourceOffer
Cluster. getAvailableResources(SupervisorDetails sd)
NormalizedResourceOffer
ISchedulingState. getAvailableResources(SupervisorDetails sd)
Get the resources on the supervisor that are available to be scheduled.List<WorkerSlot>
Cluster. getAvailableSlots(SupervisorDetails supervisor)
List<WorkerSlot>
ISchedulingState. getAvailableSlots(SupervisorDetails supervisor)
Return all the available slots on this supervisor.Set<Integer>
Cluster. getUsedPorts(SupervisorDetails supervisor)
Set<Integer>
ISchedulingState. getUsedPorts(SupervisorDetails supervisor)
Get all the used ports of this supervisor.Method parameters in org.apache.storm.scheduler with type arguments of type SupervisorDetails Modifier and Type Method 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 parameters in org.apache.storm.scheduler with type arguments of type SupervisorDetails Constructor Description Cluster(INimbus nimbus, ResourceMetrics resourceMetrics, Map<String,SupervisorDetails> supervisors, Map<String,? extends SchedulerAssignment> assignments, Topologies topologies, Map<String,Object> conf)
-
Uses of SupervisorDetails in org.apache.storm.scheduler.resource
Constructors in org.apache.storm.scheduler.resource with parameters of type SupervisorDetails Constructor Description RasNode(String nodeId, SupervisorDetails sup, Cluster cluster, Map<String,WorkerSlot> workerIdToWorker, Map<String,Map<String,Collection<ExecutorDetails>>> assignmentMap)
Create a new node.
-