org.javasimon.callback.quantiles

Class QuantilesCallback

java.lang.Object

org.javasimon.callback.CallbackSkeleton

org.javasimon.callback.quantiles.QuantilesCallback

All Implemented Interfaces:

Callback

Direct Known Subclasses:

AutoQuantilesCallback, FixedQuantilesCallback, PropertiesQuantilesCallback

public abstract class QuantilesCallback
extends CallbackSkeleton

Callback which stores data in buckets to compute quantiles. The createBuckets(org.javasimon.Stopwatch) should be implemented to configure the width and resolution of buckets. Then Buckets are stored among Simon attributes. There are 2 implementations:

• AutoQuantilesCallback tries to determine the best configuration for each Stopwatch.
• FixedQuantilesCallback uses a fixed configuration for all Stopwatches.

Since:

3.2

Author:

gquintana

See Also:

Buckets

Nested Class Summary

Nested classes/interfaces inherited from interface org.javasimon.callback.Callback

Callback.Event

Field Summary

Fields

Modifier and Type	Field and Description
static String	ATTR_NAME_BUCKETS Simon attribute name of the buckets stored in Simons after warmup time.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	QuantilesCallback() Default constructor.
protected	QuantilesCallback(BucketsType bucketsType) Constructor with buckets type.

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract Buckets	createBuckets(Stopwatch stopwatch) Create Buckets for given stopwatch.
protected Buckets	createBuckets(Stopwatch stopwatch, long min, long max, int bucketNb) Factory method to create a Buckets object using given configuration.
protected LogTemplate<Split>	createLogTemplate(Stopwatch stopwatch) Create log template for given stopwatch.
static Buckets	getBuckets(Stopwatch stopwatch) Returns the buckets attribute.
BucketsType	getBucketsType() Returns buckets type.
protected Buckets	getOrCreateBuckets(Stopwatch stopwatch) Returns the buckets attribute or create it if it does not exist.
boolean	isLogEnabled()
void	onStopwatchAdd(Stopwatch stopwatch, Split split, StopwatchSample sample) When a split is added, if buckets have been initialized, the value is added to appropriate bucket.
protected void	onStopwatchSplit(Stopwatch stopwatch, Split split) Called when there is a new split on a Stopwatch, either onStopwatchStop(org.javasimon.Split, org.javasimon.StopwatchSample) or onStopwatchAdd(org.javasimon.Stopwatch, org.javasimon.Split, org.javasimon.StopwatchSample).
void	onStopwatchStop(Split split, StopwatchSample sample) When a split is stopped, if buckets have been initialized, the value is added to appropriate bucket.
static BucketsSample	sampleBuckets(Stopwatch stopwatch) Returns the buckets attribute and sample them.
void	setLogEnabled(boolean logEnabled)

Methods inherited from class org.javasimon.callback.CallbackSkeleton

cleanup, initialize, onCounterDecrease, onCounterIncrease, onCounterSet, onManagerClear, onManagerMessage, onManagerWarning, onSimonCreated, onSimonDestroyed, onStopwatchStart

Methods inherited from class java.lang.Object

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

Field Detail

ATTR_NAME_BUCKETS

public static final String ATTR_NAME_BUCKETS

Simon attribute name of the buckets stored in Simons after warmup time.

See Also:

Constant Field Values

Constructor Detail

QuantilesCallback

protected QuantilesCallback()

Default constructor.

QuantilesCallback

protected QuantilesCallback(BucketsType bucketsType)

Constructor with buckets type.

Parameters:

bucketsType - Type of buckets

Method Detail

getBucketsType

public BucketsType getBucketsType()

Returns buckets type.

Returns:

Buckets type

isLogEnabled

public boolean isLogEnabled()

setLogEnabled

public void setLogEnabled(boolean logEnabled)

createLogTemplate

protected LogTemplate<Split> createLogTemplate(Stopwatch stopwatch)

Create log template for given stopwatch. This method can be overridden to tune logging strategy. By default, when enabled, quantiles are logged at most once per minute

Parameters:

stopwatch - Stopwatch

Returns:

Logger

getBuckets

public static Buckets getBuckets(Stopwatch stopwatch)

Returns the buckets attribute.

createBuckets

protected final Buckets createBuckets(Stopwatch stopwatch,
                    long min,
                    long max,
                    int bucketNb)

Factory method to create a Buckets object using given configuration.

Parameters:

stopwatch - Target Stopwatch

min - Min bound

max - Max bound

bucketNb - Number of buckets between min and max

Returns:

Buckets

createBuckets

protected abstract Buckets createBuckets(Stopwatch stopwatch)

Create Buckets for given stopwatch. Call createBuckets(org.javasimon.Stopwatch, long, long, int) to create a new buckets object.

Parameters:

stopwatch - Stopwatch

Returns:

Buckets

getOrCreateBuckets

protected final Buckets getOrCreateBuckets(Stopwatch stopwatch)

Returns the buckets attribute or create it if it does not exist.

sampleBuckets

public static BucketsSample sampleBuckets(Stopwatch stopwatch)

Returns the buckets attribute and sample them.

onStopwatchSplit

protected void onStopwatchSplit(Stopwatch stopwatch,
                    Split split)

Called when there is a new split on a Stopwatch, either onStopwatchStop(org.javasimon.Split, org.javasimon.StopwatchSample) or onStopwatchAdd(org.javasimon.Stopwatch, org.javasimon.Split, org.javasimon.StopwatchSample). If buckets have been initialized, the value is added to appropriate bucket.

onStopwatchStop

public void onStopwatchStop(Split split,
                   StopwatchSample sample)

When a split is stopped, if buckets have been initialized, the value is added to appropriate bucket.

Specified by:

onStopwatchStop in interface Callback

Overrides:

onStopwatchStop in class CallbackSkeleton

Parameters:

split - stopped Split

sample - stopwatch sampled after the stop

onStopwatchAdd

public void onStopwatchAdd(Stopwatch stopwatch,
                  Split split,
                  StopwatchSample sample)

When a split is added, if buckets have been initialized, the value is added to appropriate bucket.

Specified by:

onStopwatchAdd in interface Callback

Overrides:

onStopwatchAdd in class CallbackSkeleton

Parameters:

stopwatch - modified Stopwatch

split - added split object

sample - stopwatch sampled after the add