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 and Description
Load(boolean hasMetrics, double boltLoad, double connectionLoad) Create a new load

Method Summary

Modifier and Type	Method and Description
double	getBoltLoad()
double	getConnectionLoad()
double	getLoad()
boolean	hasMetrics()
String	toString()

Methods inherited from class java.lang.Object

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

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 loaded

connectionLoad - the load as reported by the connection to the bolt 0.0 no load 1.0 fully loaded.

Method Detail

hasMetrics

public boolean hasMetrics()

Returns:

true if metrics have been reported so far.

getBoltLoad

public double getBoltLoad()

Returns:

the load as reported by the bolt.

getConnectionLoad

public double getConnectionLoad()

Returns:

the load as reported by the connection

getLoad

public double getLoad()

Returns:

the load that is a combination of sub loads.

toString

public String toString()

Overrides:

toString in class Object