Uses of Class
org.apache.storm.scheduler.resource.normalization.NormalizedResourceRequest
Package
Description
-
Uses of NormalizedResourceRequest in org.apache.storm.scheduler
Modifier 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. ignores shared memory.TopologyDetails.getApproximateTotalResources()
Get an approximate total resources needed for this topology. ignores shared memory.TopologyDetails.getTaskResourceReqList
(ExecutorDetails exec) get the resources requirements for a executor.TopologyDetails.getTotalResources
(ExecutorDetails exec) Get the total resource requirement for an executor.Modifier and TypeMethodDescriptionvoid
TopologyDetails.addResourcesForExec
(ExecutorDetails exec, NormalizedResourceRequest resourceList) add resource requirements for a executor. -
Uses of NormalizedResourceRequest in org.apache.storm.scheduler.resource
Modifier 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) Modifier 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
Modifier 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.