Package org.apache.storm.grouping
Class Load
- java.lang.Object
-
- org.apache.storm.grouping.Load
-
public class Load extends Object
Represents the load that a Bolt is currently under to help in deciding where to route a tuple, to help balance the load.
-
-
Constructor Summary
Constructors Constructor Description Load(boolean hasMetrics, double boltLoad, double connectionLoad)Create a new load.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description doublegetBoltLoad()Get bolt load.doublegetConnectionLoad()Get connection load.doublegetLoad()Get load.booleanhasMetrics()Check whether has metrics.StringtoString()
-
-
-
Constructor Detail
-
Load
public Load(boolean hasMetrics, double boltLoad, double connectionLoad)Create a new load.- Parameters:
hasMetrics- have metrics been reported yet?boltLoad- the load as reported by the bolt 0.0 no load 1.0 fully loadedconnectionLoad- the load as reported by the connection to the bolt 0.0 no load 1.0 fully loaded.
-
-
Method Detail
-
hasMetrics
public boolean hasMetrics()
Check whether has metrics.- Returns:
- true if metrics have been reported so far.
-
getBoltLoad
public double getBoltLoad()
Get bolt load.- Returns:
- the load as reported by the bolt.
-
getConnectionLoad
public double getConnectionLoad()
Get connection load.- Returns:
- the load as reported by the connection
-
getLoad
public double getLoad()
Get load.- Returns:
- the load that is a combination of sub loads.
-
-