backtype.storm.utils

Class DefaultMaxSpoutPendingTuner

java.lang.Object

backtype.storm.utils.DefaultMaxSpoutPendingTuner

public class DefaultMaxSpoutPendingTuner
extends java.lang.Object

This is a class that helps to auto tune the max spout pending value

Constructor Summary

Constructors

Constructor and Description
DefaultMaxSpoutPendingTuner(float autoTuneFactor, double progressBound) Conv constructor when initing from a non-set initial value
DefaultMaxSpoutPendingTuner(java.lang.Long maxSpoutPending, float autoTuneFactor, double progressBound)

Method Summary

Modifier and Type	Method and Description
void	autoTune(java.lang.Long progress)
java.lang.Long	get()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMaxSpoutPendingTuner

public DefaultMaxSpoutPendingTuner(float autoTuneFactor,
                                   double progressBound)

Conv constructor when initing from a non-set initial value

DefaultMaxSpoutPendingTuner

public DefaultMaxSpoutPendingTuner(java.lang.Long maxSpoutPending,
                                   float autoTuneFactor,
                                   double progressBound)

Method Detail

get

public java.lang.Long get()

autoTune

public void autoTune(java.lang.Long progress)