Uses of Class
org.apache.storm.scheduler.SupervisorDetails
Packages that use SupervisorDetails
Package
Description
-
Uses of SupervisorDetails in org.apache.storm.daemon.nimbus
Method parameters in org.apache.storm.daemon.nimbus with type arguments of type SupervisorDetailsModifier and TypeMethodDescriptionNimbus.StandaloneINimbus.allSlotsAvailableForScheduling
(Collection<SupervisorDetails> supervisors, Topologies topologies, Set<String> topologiesMissingAssignments) 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 SupervisorDetailsModifier and TypeMethodDescriptionCluster.getSupervisorById
(String nodeId) ISchedulingState.getSupervisorById
(String nodeId) Get a specific supervisor with thenodeId
.Methods in org.apache.storm.scheduler that return types with arguments of type SupervisorDetailsModifier and TypeMethodDescriptionCluster.getSupervisors()
ISchedulingState.getSupervisors()
Get all the supervisors.Cluster.getSupervisorsByHost
(String host) ISchedulingState.getSupervisorsByHost
(String host) Get all the supervisors on the specifiedhost
.Methods in org.apache.storm.scheduler with parameters of type SupervisorDetailsModifier and TypeMethodDescriptionCluster.getAssignablePorts
(SupervisorDetails supervisor) ISchedulingState.getAssignablePorts
(SupervisorDetails supervisor) Get the ports that are not blacklisted.Cluster.getAssignableSlots
(SupervisorDetails supervisor) ISchedulingState.getAssignableSlots
(SupervisorDetails supervisor) Return all non-blacklisted slots on this supervisor.Cluster.getAvailablePorts
(SupervisorDetails supervisor) ISchedulingState.getAvailablePorts
(SupervisorDetails supervisor) Return the available ports of this supervisor.Cluster.getAvailableResources
(SupervisorDetails sd) ISchedulingState.getAvailableResources
(SupervisorDetails sd) Get the resources on the supervisor that are available to be scheduled.Cluster.getAvailableSlots
(SupervisorDetails supervisor) ISchedulingState.getAvailableSlots
(SupervisorDetails supervisor) Return all the available slots on this supervisor.Cluster.getUsedPorts
(SupervisorDetails supervisor) ISchedulingState.getUsedPorts
(SupervisorDetails supervisor) Get all the used ports of this supervisor.Method parameters in org.apache.storm.scheduler with type arguments of type SupervisorDetailsModifier and TypeMethodDescriptionINimbus.allSlotsAvailableForScheduling
(Collection<SupervisorDetails> existingSupervisors, Topologies topologies, Set<String> topologiesMissingAssignments) Returns all slots that are available for the next round of scheduling.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 SupervisorDetailsModifierConstructorDescriptionCluster
(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 SupervisorDetailsModifierConstructorDescriptionRasNode
(String nodeId, SupervisorDetails sup, Cluster cluster, Map<String, WorkerSlot> workerIdToWorker, Map<String, Map<String, Collection<ExecutorDetails>>> assignmentMap) Create a new node.