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

Packages that use TopologyDetails

Package	Description
org.apache.storm.scheduler
org.apache.storm.scheduler.multitenant
org.apache.storm.scheduler.resource
org.apache.storm.scheduler.resource.strategies.eviction
org.apache.storm.scheduler.resource.strategies.priority
org.apache.storm.scheduler.resource.strategies.scheduling

Uses of TopologyDetails in org.apache.storm.scheduler

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

Modifier and Type	Method and Description
TopologyDetails	Topologies.getById(String topologyId)
TopologyDetails	Topologies.getByName(String topologyName)

Methods in org.apache.storm.scheduler that return types with arguments of type TopologyDetails

Modifier and Type	Method and Description
Collection<TopologyDetails>	Topologies.getTopologies()
List<TopologyDetails>	Cluster.needsSchedulingTopologies(Topologies topologies)

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

Modifier and Type	Method and Description
int	Cluster.getAssignedNumWorkers(TopologyDetails topology)
Map<String,List<ExecutorDetails>>	Cluster.getNeedsSchedulingComponentToExecutors(TopologyDetails topology)
Map<ExecutorDetails,String>	Cluster.getNeedsSchedulingExecutorToComponents(TopologyDetails topology)
Collection<ExecutorDetails>	Cluster.getUnassignedExecutors(TopologyDetails topology) get the unassigned executors of the topology.
boolean	Cluster.needsScheduling(TopologyDetails topology) Does the topology need scheduling?

Constructor parameters in org.apache.storm.scheduler with type arguments of type TopologyDetails

Constructor and Description
Topologies(Map<String,TopologyDetails> topologies)

Uses of TopologyDetails in org.apache.storm.scheduler.multitenant

Methods in org.apache.storm.scheduler.multitenant with parameters of type TopologyDetails

Modifier and Type	Method and Description
abstract void	NodePool.addTopology(TopologyDetails td) Add a topology to the pool
void	IsolatedPool.addTopology(TopologyDetails td)
void	FreePool.addTopology(TopologyDetails td)
void	DefaultPool.addTopology(TopologyDetails td)
abstract boolean	NodePool.canAdd(TopologyDetails td) Check if this topology can be added to this pool
boolean	IsolatedPool.canAdd(TopologyDetails td)
boolean	FreePool.canAdd(TopologyDetails td)
boolean	DefaultPool.canAdd(TopologyDetails td)

Constructors in org.apache.storm.scheduler.multitenant with parameters of type TopologyDetails

Constructor and Description
RoundRobinSlotScheduler(TopologyDetails td, int slotsToUse, Cluster cluster) Create a new scheduler for a given topology

Uses of TopologyDetails in org.apache.storm.scheduler.resource

Methods in org.apache.storm.scheduler.resource that return TopologyDetails

Modifier and Type	Method and Description
TopologyDetails	RAS_Node.findTopologyUsingWorker(WorkerSlot ws) Find a which topology is running on a worker slot
TopologyDetails	User.getNextTopologyToSchedule()
TopologyDetails	User.getRunningTopologyWithLowestPriority()

Methods in org.apache.storm.scheduler.resource that return types with arguments of type TopologyDetails

Modifier and Type	Method and Description
Set<TopologyDetails>	User.getTopologiesAttempted()
Set<TopologyDetails>	User.getTopologiesInvalid()
Set<TopologyDetails>	User.getTopologiesPending()
Set<TopologyDetails>	User.getTopologiesRunning()

Methods in org.apache.storm.scheduler.resource with parameters of type TopologyDetails

Modifier and Type	Method and Description
void	User.addTopologyToAttemptedQueue(TopologyDetails topo)
void	User.addTopologyToInvalidQueue(TopologyDetails topo)
void	User.addTopologyToPendingQueue(TopologyDetails topo)
void	User.addTopologyToPendingQueue(TopologyDetails topo, Cluster cluster)
void	User.addTopologyToRunningQueue(TopologyDetails topo)
void	User.addTopologyToRunningQueue(TopologyDetails topo, Cluster cluster)
void	RAS_Node.assign(WorkerSlot target, TopologyDetails td, Collection<ExecutorDetails> executors) Assigns a worker to a node
void	RAS_Node.consumeResourcesforTask(ExecutorDetails exec, TopologyDetails topo) Consumes a certain amount of resources for a executor in a topology.
void	RAS_Node.freeResourcesForTask(ExecutorDetails exec, TopologyDetails topo) frees the amount of resources for a executor in a topology.
void	User.moveTopoFromPendingToAttempted(TopologyDetails topo)
void	User.moveTopoFromPendingToAttempted(TopologyDetails topo, Cluster cluster)
void	User.moveTopoFromPendingToInvalid(TopologyDetails topo)
void	User.moveTopoFromPendingToInvalid(TopologyDetails topo, Cluster cluster)
void	User.moveTopoFromPendingToRunning(TopologyDetails topo)
void	User.moveTopoFromPendingToRunning(TopologyDetails topo, Cluster cluster)
void	User.moveTopoFromRunningToPending(TopologyDetails topo)
void	User.moveTopoFromRunningToPending(TopologyDetails topo, Cluster cluster)
void	ResourceAwareScheduler.scheduleTopology(TopologyDetails td)

Uses of TopologyDetails in org.apache.storm.scheduler.resource.strategies.eviction

Methods in org.apache.storm.scheduler.resource.strategies.eviction with parameters of type TopologyDetails

Modifier and Type	Method and Description
boolean	IEvictionStrategy.makeSpaceForTopo(TopologyDetails td) This method when invoked should attempt to make space on the cluster so that the topology specified can be scheduled
boolean	DefaultEvictionStrategy.makeSpaceForTopo(TopologyDetails td)

Uses of TopologyDetails in org.apache.storm.scheduler.resource.strategies.priority

Methods in org.apache.storm.scheduler.resource.strategies.priority that return TopologyDetails

Modifier and Type	Method and Description
TopologyDetails	ISchedulingPriorityStrategy.getNextTopologyToSchedule() Gets the next topology to schedule
TopologyDetails	DefaultSchedulingPriorityStrategy.getNextTopologyToSchedule()

Uses of TopologyDetails in org.apache.storm.scheduler.resource.strategies.scheduling

Methods in org.apache.storm.scheduler.resource.strategies.scheduling with parameters of type TopologyDetails

Modifier and Type	Method and Description
SchedulingResult	IStrategy.schedule(TopologyDetails td) This method is invoked to calcuate a scheduling for topology td
SchedulingResult	DefaultResourceAwareStrategy.schedule(TopologyDetails td)