Uses of Class
org.apache.storm.scheduler.Topologies

Packages that use Topologies

Package	Description
org.apache.storm.daemon.nimbus
org.apache.storm.scheduler
org.apache.storm.scheduler.blacklist
org.apache.storm.scheduler.blacklist.strategies
org.apache.storm.scheduler.multitenant
org.apache.storm.scheduler.resource

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 and Description
Collection<WorkerSlot>	Nimbus.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

Methods in org.apache.storm.scheduler that return Topologies

Modifier and Type	Method and Description
Topologies	Cluster.getTopologies()
Topologies	ISchedulingState.getTopologies() Get all of the topologies.

Methods in org.apache.storm.scheduler with parameters of type Topologies

Modifier and Type	Method and 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.
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	IScheduler.schedule(Topologies topologies, Cluster cluster) Set assignments for the topologies which needs scheduling.
void	IsolationScheduler.schedule(Topologies topologies, Cluster cluster)
void	EvenScheduler.schedule(Topologies topologies, Cluster cluster)
static void	EvenScheduler.scheduleTopologiesEvenly(Topologies topologies, Cluster cluster)

Constructors in org.apache.storm.scheduler with parameters of type Topologies

Constructor and 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 and Description
void	BlacklistScheduler.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 and 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 and Description
void	MultitenantScheduler.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 and Description
void	ResourceAwareScheduler.schedule(Topologies topologies, Cluster cluster)