org.apache.storm.scheduler.resource

Class ResourceUtils

java.lang.Object

org.apache.storm.scheduler.resource.ResourceUtils

public class ResourceUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
ResourceUtils()

Method Summary

Modifier and Type	Method and Description
static double	avg(Collection<Double> list) Caculate the average of a collection of doubles
static void	checkInitCPU(Map<String,Double> topology_resources, String Com, Map topologyConf)
static void	checkInitMem(Map<String,Double> topology_resources, String Com, Map topologyConf)
static void	checkIntialization(Map<String,Double> topology_resources, String Com, Map topologyConf)
static Map<String,Map<String,Double>>	getBoltsResources(StormTopology topology, Map topologyConf)
static Map<String,Map<String,Double>>	getSpoutsResources(StormTopology topology, Map topologyConf)
static Map<String,Double>	parseResources(String input)
static String	printScheduling(Cluster cluster, Topologies topologies) print scheduling for debug purposes
static double	sum(Collection<Double> list) Calculate the sum of a collection of doubles

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResourceUtils

public ResourceUtils()

Method Detail

getBoltsResources

public static Map<String,Map<String,Double>> getBoltsResources(StormTopology topology,
                                                               Map topologyConf)

getSpoutsResources

public static Map<String,Map<String,Double>> getSpoutsResources(StormTopology topology,
                                                                Map topologyConf)

checkIntialization

public static void checkIntialization(Map<String,Double> topology_resources,
                                      String Com,
                                      Map topologyConf)

checkInitMem

public static void checkInitMem(Map<String,Double> topology_resources,
                                String Com,
                                Map topologyConf)

checkInitCPU

public static void checkInitCPU(Map<String,Double> topology_resources,
                                String Com,
                                Map topologyConf)

parseResources

public static Map<String,Double> parseResources(String input)

printScheduling

public static String printScheduling(Cluster cluster,
                                     Topologies topologies)

print scheduling for debug purposes

Parameters:

cluster -

topologies -

sum

public static double sum(Collection<Double> list)

Calculate the sum of a collection of doubles

Parameters:

list - collection of doubles

Returns:

the sum of of collection of doubles

avg

public static double avg(Collection<Double> list)

Caculate the average of a collection of doubles

Parameters:

list - a collection of doubles

Returns:

the average of collection of doubles