seda.sandStorm.internal
Class AggThrottle
java.lang.Object
seda.sandStorm.internal.AggThrottle
class AggThrottle
- extends java.lang.Object
AggThrottle is used by thread managers to adjust their aggregation
level based on observations of stage throughput.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
DEBUG
private static final boolean DEBUG
- See Also:
- Constant Field Values
stage
private StageWrapperIF stage
name
private java.lang.String name
mgr
private ManagerIF mgr
bestThroughput
private double bestThroughput
lastThroughput
private double lastThroughput
bestTarget
private int bestTarget
lastEvents
private long lastEvents
lastMeasurementTime
private long lastMeasurementTime
measurementCount
private int measurementCount
adjustCount
private int adjustCount
STATE_DECREASING
private static final int STATE_DECREASING
- See Also:
- Constant Field Values
STATE_INCREASING
private static final int STATE_INCREASING
- See Also:
- Constant Field Values
state
private int state
increase_count
private int increase_count
ADJUST_DELAY
private static final int ADJUST_DELAY
- See Also:
- Constant Field Values
minAggregation
private int minAggregation
maxAggregation
private int maxAggregation
recalcWindow
private int recalcWindow
smoothConst
private double smoothConst
REDUCE_FACTOR
private static final double REDUCE_FACTOR
- See Also:
- Constant Field Values
INCREASE_FACTOR
private static final double INCREASE_FACTOR
- See Also:
- Constant Field Values
LOW_WATER
private static final double LOW_WATER
- See Also:
- Constant Field Values
HIGH_WATER
private static final double HIGH_WATER
- See Also:
- Constant Field Values
VERY_LOW_WATER
private static final double VERY_LOW_WATER
- See Also:
- Constant Field Values
VERY_HIGH_WATER
private static final double VERY_HIGH_WATER
- See Also:
- Constant Field Values
aggregationTarget
private int aggregationTarget
rand
private java.util.Random rand
AggThrottle
AggThrottle(StageWrapperIF stage,
ManagerIF mgr)
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
getAggTarget
int getAggTarget()