Class ResourceUtils
java.lang.Object
org.apache.storm.scheduler.resource.ResourceUtils
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic NormalizedResourceRequestgetBoltResources(StormTopology topology, Map<String, Object> topologyConf, String componentId) static Map<String,NormalizedResourceRequest> getBoltsResources(StormTopology topology, Map<String, Object> topologyConf) static StringgetCorrespondingLegacyResourceName(String normalizedResourceName) static StringgetJsonWithUpdatedResources(String jsonConf, Map<String, Double> resourceUpdates) static NormalizedResourceRequestgetSpoutResources(StormTopology topology, Map<String, Object> topologyConf, String componentId) static Map<String,NormalizedResourceRequest> getSpoutsResources(StormTopology topology, Map<String, Object> topologyConf) static voidupdateStormTopologyResources(StormTopology topology, Map<String, Map<String, Double>> resourceUpdatesMap) 
- 
Constructor Details- 
ResourceUtilspublic ResourceUtils()
 
- 
- 
Method Details- 
getBoltResourcespublic static NormalizedResourceRequest getBoltResources(StormTopology topology, Map<String, Object> topologyConf, String componentId) 
- 
getBoltsResourcespublic static Map<String,NormalizedResourceRequest> getBoltsResources(StormTopology topology, Map<String, Object> topologyConf) 
- 
getSpoutResourcespublic static NormalizedResourceRequest getSpoutResources(StormTopology topology, Map<String, Object> topologyConf, String componentId) 
- 
getSpoutsResourcespublic static Map<String,NormalizedResourceRequest> getSpoutsResources(StormTopology topology, Map<String, Object> topologyConf) 
- 
updateStormTopologyResources
- 
getCorrespondingLegacyResourceName
- 
getJsonWithUpdatedResources
 
-