Uses of Class
org.apache.storm.scheduler.Topologies
Package
Description
-
Uses of Topologies in org.apache.storm.daemon.nimbus
Modifier and TypeMethodDescriptionNimbus.StandaloneINimbus.allSlotsAvailableForScheduling
(Collection<SupervisorDetails> supervisors, Topologies topologies, Set<String> topologiesMissingAssignments) void
Nimbus.StandaloneINimbus.assignSlots
(Topologies topologies, Map<String, Collection<WorkerSlot>> newSlotsByTopologyId) -
Uses of Topologies in org.apache.storm.scheduler
Modifier and TypeMethodDescriptionCluster.getTopologies()
ISchedulingState.getTopologies()
Get all of the topologies.Modifier and TypeMethodDescriptionINimbus.allSlotsAvailableForScheduling
(Collection<SupervisorDetails> existingSupervisors, Topologies topologies, Set<String> topologiesMissingAssignments) Returns all slots that are available for the next round of scheduling.void
INimbus.assignSlots
(Topologies topologies, Map<String, Collection<WorkerSlot>> newSlotsByTopologyId) this is called after the assignment is changed in ZK.static void
DefaultScheduler.defaultSchedule
(Topologies topologies, Cluster cluster) void
DefaultScheduler.schedule
(Topologies topologies, Cluster cluster) void
EvenScheduler.schedule
(Topologies topologies, Cluster cluster) void
IScheduler.schedule
(Topologies topologies, Cluster cluster) Set assignments for the topologies which needs scheduling.void
IsolationScheduler.schedule
(Topologies topologies, Cluster cluster) static void
EvenScheduler.scheduleTopologiesEvenly
(Topologies topologies, Cluster cluster) ModifierConstructorDescriptionCluster
(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
Modifier and TypeMethodDescriptionvoid
BlacklistScheduler.schedule
(Topologies topologies, Cluster cluster) -
Uses of Topologies in org.apache.storm.scheduler.blacklist.strategies
Modifier 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
Modifier and TypeMethodDescriptionvoid
MultitenantScheduler.schedule
(Topologies topologies, Cluster cluster) -
Uses of Topologies in org.apache.storm.scheduler.resource
Modifier and TypeMethodDescriptionvoid
ResourceAwareScheduler.schedule
(Topologies topologies, Cluster cluster)