Class ResourceUtils
java.lang.Object
org.apache.storm.scheduler.resource.ResourceUtils
-
Constructor Summary
Constructors -
Method Summary
Modifier 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
-
ResourceUtils
public ResourceUtils()
-
-
Method Details
-
getBoltResources
public static NormalizedResourceRequest getBoltResources(StormTopology topology, Map<String, Object> topologyConf, String componentId) -
getBoltsResources
public static Map<String,NormalizedResourceRequest> getBoltsResources(StormTopology topology, Map<String, Object> topologyConf) -
getSpoutResources
public static NormalizedResourceRequest getSpoutResources(StormTopology topology, Map<String, Object> topologyConf, String componentId) -
getSpoutsResources
public static Map<String,NormalizedResourceRequest> getSpoutsResources(StormTopology topology, Map<String, Object> topologyConf) -
updateStormTopologyResources
-
getCorrespondingLegacyResourceName
-
getJsonWithUpdatedResources
-