Uses of Class
org.apache.storm.scheduler.Topologies
Packages that use Topologies
Package
Description
- 
Uses of Topologies in org.apache.storm.daemon.nimbusMethods 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.schedulerMethods 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.blacklistMethods 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.strategiesMethods 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.multitenantMethods 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.resourceMethods in org.apache.storm.scheduler.resource with parameters of type TopologiesModifier and TypeMethodDescriptionvoidResourceAwareScheduler.schedule(Topologies topologies, Cluster cluster)