Uses of Class
org.apache.storm.scheduler.Topologies
Packages that use Topologies
Package
Description
-
Uses of Topologies in org.apache.storm.daemon.nimbus
Methods in org.apache.storm.daemon.nimbus with parameters of type TopologiesModifier and TypeMethodDescriptionNimbus.StandaloneINimbus.allSlotsAvailableForScheduling(Collection<SupervisorDetails> supervisors, Topologies topologies, Set<String> topologiesMissingAssignments) voidNimbus.StandaloneINimbus.assignSlots(Topologies topologies, Map<String, Collection<WorkerSlot>> newSlotsByTopologyId) -
Uses of Topologies in org.apache.storm.scheduler
Methods in org.apache.storm.scheduler that return TopologiesModifier and TypeMethodDescriptionCluster.getTopologies()ISchedulingState.getTopologies()Get all of the topologies.Methods in org.apache.storm.scheduler with parameters of type TopologiesModifier and TypeMethodDescriptionINimbus.allSlotsAvailableForScheduling(Collection<SupervisorDetails> existingSupervisors, Topologies topologies, Set<String> topologiesMissingAssignments) Returns all slots that are available for the next round of scheduling.voidINimbus.assignSlots(Topologies topologies, Map<String, Collection<WorkerSlot>> newSlotsByTopologyId) this is called after the assignment is changed in ZK.static voidDefaultScheduler.defaultSchedule(Topologies topologies, Cluster cluster) voidDefaultScheduler.schedule(Topologies topologies, Cluster cluster) voidEvenScheduler.schedule(Topologies topologies, Cluster cluster) voidIScheduler.schedule(Topologies topologies, Cluster cluster) Set assignments for the topologies which needs scheduling.voidIsolationScheduler.schedule(Topologies topologies, Cluster cluster) static voidEvenScheduler.scheduleTopologiesEvenly(Topologies topologies, Cluster cluster) Constructors in org.apache.storm.scheduler with parameters of type TopologiesModifierConstructorDescriptionCluster(Cluster src, Topologies topologies) Testing Constructor that takes an existing cluster and replaces the topologies in it.Cluster(INimbus nimbus, ResourceMetrics resourceMetrics, Map<String, SupervisorDetails> supervisors, Map<String, ? extends SchedulerAssignment> assignments, Topologies topologies, Map<String, Object> conf) Topologies(Topologies src) Copy constructor. -
Uses of Topologies in org.apache.storm.scheduler.blacklist
Methods in org.apache.storm.scheduler.blacklist with parameters of type TopologiesModifier and TypeMethodDescriptionvoidBlacklistScheduler.schedule(Topologies topologies, Cluster cluster) -
Uses of Topologies in org.apache.storm.scheduler.blacklist.strategies
Methods in org.apache.storm.scheduler.blacklist.strategies with parameters of type TopologiesModifier and TypeMethodDescriptionDefaultBlacklistStrategy.getBlacklist(List<Map<String, Set<Integer>>> supervisorsWithFailures, List<Map<String, Integer>> sendAssignmentFailureCount, Cluster cluster, Topologies topologies) IBlacklistStrategy.getBlacklist(List<Map<String, Set<Integer>>> badSupervisorsToleranceSlidingWindow, List<Map<String, Integer>> sendAssignmentFailureCount, Cluster cluster, Topologies topologies) Get blacklist by blacklist strategy. -
Uses of Topologies in org.apache.storm.scheduler.multitenant
Methods in org.apache.storm.scheduler.multitenant with parameters of type TopologiesModifier and TypeMethodDescriptionvoidMultitenantScheduler.schedule(Topologies topologies, Cluster cluster) -
Uses of Topologies in org.apache.storm.scheduler.resource
Methods in org.apache.storm.scheduler.resource with parameters of type TopologiesModifier and TypeMethodDescriptionvoidResourceAwareScheduler.schedule(Topologies topologies, Cluster cluster)