Uses of Class
org.apache.storm.generated.WorkerResources

Packages that use WorkerResources

Package	Description
org.apache.storm.generated
org.apache.storm.scheduler
org.apache.storm.scheduler.resource.normalization
org.apache.storm.stats

Uses of WorkerResources in org.apache.storm.generated

Methods in org.apache.storm.generated that return WorkerResources

Modifier and Type	Method and Description
WorkerResources	WorkerResources.deepCopy()
WorkerResources	LocalAssignment.get_resources()

Methods in org.apache.storm.generated that return types with arguments of type WorkerResources

Modifier and Type	Method and Description
Map<NodeInfo,WorkerResources>	Assignment.get_worker_resources()

Methods in org.apache.storm.generated with parameters of type WorkerResources

Modifier and Type	Method and Description
int	WorkerResources.compareTo(WorkerResources other)
boolean	WorkerResources.equals(WorkerResources that)
void	Assignment.put_to_worker_resources(NodeInfo key, WorkerResources val)
void	LocalAssignment.set_resources(WorkerResources resources)

Method parameters in org.apache.storm.generated with type arguments of type WorkerResources

Modifier and Type	Method and Description
void	Assignment.set_worker_resources(Map<NodeInfo,WorkerResources> worker_resources)

Constructors in org.apache.storm.generated with parameters of type WorkerResources

Constructor and Description
WorkerResources(WorkerResources other) Performs a deep copy on other.

Uses of WorkerResources in org.apache.storm.scheduler

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

Modifier and Type	Method and Description
WorkerResources	Cluster.getWorkerResources(WorkerSlot ws)
WorkerResources	ISchedulingState.getWorkerResources(WorkerSlot ws) Get the resources for a given slot.

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

Modifier and Type	Method and Description
Map<WorkerSlot,WorkerResources>	SchedulerAssignment.getScheduledResources() Get the slot to resource mapping.
Map<WorkerSlot,WorkerResources>	SchedulerAssignmentImpl.getScheduledResources()
Map<String,Map<WorkerSlot,WorkerResources>>	Cluster.getWorkerResourcesMap()
Map<String,Map<WorkerSlot,WorkerResources>>	ISchedulingState.getWorkerResourcesMap() Gets the reference to the full topology->worker resource map.

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

Modifier and Type	Method and Description
void	SchedulerAssignmentImpl.assign(WorkerSlot slot, Collection<ExecutorDetails> executors, WorkerResources slotResources) Assign the slot to executors.

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

Constructor and Description
SchedulerAssignmentImpl(String topologyId, Map<ExecutorDetails,WorkerSlot> executorToSlot, Map<WorkerSlot,WorkerResources> resources, Map<String,Double> nodeIdToTotalSharedOffHeap) Create a new assignment.

Uses of WorkerResources in org.apache.storm.scheduler.resource.normalization

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

Modifier and Type	Method and Description
void	NormalizedResources.add(WorkerResources value) Add the resources from a worker to this.
void	NormalizedResourceRequest.add(WorkerResources value) Add the resources from a worker to those in this.
boolean	NormalizedResources.remove(WorkerResources value) Remove the resources of a worker from this.
boolean	NormalizedResourceOffer.remove(WorkerResources other, ResourceMetrics resourceMetrics) Remove the resources in other from this.

Uses of WorkerResources in org.apache.storm.stats

Method parameters in org.apache.storm.stats with type arguments of type WorkerResources

Modifier and Type	Method and Description
static List<WorkerSummary>	StatsUtil.aggWorkerStats(String stormId, String stormName, Map<Integer,String> task2Component, Map<List<Integer>,Map<String,Object>> beats, Map<List<Long>,List<Object>> exec2NodePort, Map<String,String> nodeHost, Map<WorkerSlot,WorkerResources> worker2Resources, boolean includeSys, boolean userAuthorized, String filterSupervisor, String owner) aggregate statistics per worker for a topology.