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 -
-
Uses of WorkerResources in org.apache.storm.generated
Methods in org.apache.storm.generated that return WorkerResources Modifier and Type Method 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 Description Map<NodeInfo,WorkerResources>
Assignment. get_worker_resources()
Methods in org.apache.storm.generated with parameters of type WorkerResources Modifier and Type Method 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 Description void
Assignment. set_worker_resources(Map<NodeInfo,WorkerResources> worker_resources)
Constructors in org.apache.storm.generated with parameters of type WorkerResources Constructor 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 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 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 Description SupervisorResources
SupervisorResources. add(WorkerResources wr)
void
SchedulerAssignmentImpl. assign(WorkerSlot slot, Collection<ExecutorDetails> executors, WorkerResources slotResources)
Assign the slot to executors. -
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 Description void
NormalizedResourceRequest. add(WorkerResources value)
Add the resources from a worker to those in this.void
NormalizedResources. add(WorkerResources value)
Add the resources from a worker to this.boolean
NormalizedResourceOffer. remove(WorkerResources other, ResourceMetrics resourceMetrics)
Remove the resources in other from this.boolean
NormalizedResources. remove(WorkerResources value)
Remove the resources of a worker from this.
-