Uses of Class
org.apache.storm.scheduler.SupervisorDetails
Package
Description
-
Uses of SupervisorDetails in org.apache.storm.daemon.nimbus
Modifier 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
Modifier and TypeMethodDescriptionCluster.getSupervisorById
(String nodeId) ISchedulingState.getSupervisorById
(String nodeId) Get a specific supervisor with thenodeId
.Modifier and TypeMethodDescriptionCluster.getSupervisors()
ISchedulingState.getSupervisors()
Get all the supervisors.Cluster.getSupervisorsByHost
(String host) ISchedulingState.getSupervisorsByHost
(String host) Get all the supervisors on the specifiedhost
.Modifier 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.Modifier 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.ModifierConstructorDescriptionCluster
(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
ModifierConstructorDescriptionRasNode
(String nodeId, SupervisorDetails sup, Cluster cluster, Map<String, WorkerSlot> workerIdToWorker, Map<String, Map<String, Collection<ExecutorDetails>>> assignmentMap) Create a new node.