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 TypeMethodDescriptionvoidTopologyDetails.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 NormalizedResourceRequestResourceUtils.getBoltResources(StormTopology topology, Map<String, Object> topologyConf, String componentId) static NormalizedResourceRequestResourceUtils.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 TypeMethodDescriptionvoidNormalizedResourceRequest.add(NormalizedResourceRequest other) Add the resources in other to this.booleanNormalizedResourceOffer.couldFit(double minWorkerCpu, NormalizedResourceRequest requestedResources) Is there any possibility that a resource request could ever fit on this.voidNormalizedResourceOffer.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.