Uses of Class
org.apache.storm.scheduler.resource.normalization.NormalizedResourceRequest
Packages that use NormalizedResourceRequest
Package
Description
-
Uses of NormalizedResourceRequest in org.apache.storm.scheduler
Methods in org.apache.storm.scheduler that return NormalizedResourceRequestModifier and TypeMethodDescriptionCluster.getAllScheduledResourcesForNode
(String nodeId) ISchedulingState.getAllScheduledResourcesForNode
(String nodeId) Get all scheduled resources for node.TopologyDetails.getApproximateResources
(Set<ExecutorDetails> execs) Get approximate resources for given topology executors.TopologyDetails.getApproximateTotalResources()
Get an approximate total resources needed for this topology.TopologyDetails.getTaskResourceReqList
(ExecutorDetails exec) get the resources requirements for a executor.TopologyDetails.getTotalResources
(ExecutorDetails exec) Get the total resource requirement for an executor.Methods in org.apache.storm.scheduler with parameters of type NormalizedResourceRequestModifier and TypeMethodDescriptionvoid
TopologyDetails.addResourcesForExec
(ExecutorDetails exec, NormalizedResourceRequest resourceList) add resource requirements for a executor. -
Uses of NormalizedResourceRequest in org.apache.storm.scheduler.resource
Methods in org.apache.storm.scheduler.resource that return NormalizedResourceRequestModifier and TypeMethodDescriptionstatic NormalizedResourceRequest
ResourceUtils.getBoltResources
(StormTopology topology, Map<String, Object> topologyConf, String componentId) static NormalizedResourceRequest
ResourceUtils.getSpoutResources
(StormTopology topology, Map<String, Object> topologyConf, String componentId) Methods in org.apache.storm.scheduler.resource that return types with arguments of type NormalizedResourceRequestModifier and TypeMethodDescriptionstatic Map<String,
NormalizedResourceRequest> ResourceUtils.getBoltsResources
(StormTopology topology, Map<String, Object> topologyConf) static Map<String,
NormalizedResourceRequest> ResourceUtils.getSpoutsResources
(StormTopology topology, Map<String, Object> topologyConf) -
Uses of NormalizedResourceRequest in org.apache.storm.scheduler.resource.normalization
Methods in org.apache.storm.scheduler.resource.normalization with parameters of type NormalizedResourceRequestModifier and TypeMethodDescriptionvoid
NormalizedResourceRequest.add
(NormalizedResourceRequest other) Add the resources in other to this.boolean
NormalizedResourceOffer.couldFit
(double minWorkerCpu, NormalizedResourceRequest requestedResources) Is there any possibility that a resource request could ever fit on this.void
NormalizedResourceOffer.updateForRareResourceAffinity
(NormalizedResourceRequest requestedResources) If a node or rack has a kind of resource not in a request, make that resource negative so when sorting that node or rack will be less likely to be selected.