Uses of Class
org.apache.storm.scheduler.Topologies
-
-
Uses of Topologies in org.apache.storm.daemon.nimbus
Methods in org.apache.storm.daemon.nimbus with parameters of type Topologies Modifier and Type Method Description Collection<WorkerSlot>Nimbus.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 Topologies Modifier and Type Method Description TopologiesCluster. getTopologies()TopologiesISchedulingState. getTopologies()Get all of the topologies.Methods in org.apache.storm.scheduler with parameters of type Topologies 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.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 Topologies Constructor Description Cluster(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 Topologies Modifier and Type Method Description voidBlacklistScheduler. 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 Topologies Modifier and Type Method Description Set<String>DefaultBlacklistStrategy. getBlacklist(List<Map<String,Set<Integer>>> supervisorsWithFailures, List<Map<String,Integer>> sendAssignmentFailureCount, Cluster cluster, Topologies topologies)Set<String>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 Topologies Modifier and Type Method Description voidMultitenantScheduler. 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 Topologies Modifier and Type Method Description voidResourceAwareScheduler. schedule(Topologies topologies, Cluster cluster)
-