org.spf4j.perf.impl

Class QuantizedAccumulator

java.lang.Object

org.spf4j.perf.impl.AbstractMeasurementAccumulator

org.spf4j.perf.impl.QuantizedAccumulator

All Implemented Interfaces:

MeasurementAccumulator, MeasurementRecorder

@ThreadSafe
 @ParametersAreNonnullByDefault
public final class QuantizedAccumulator
extends AbstractMeasurementAccumulator

inspired by DTrace LLQUANTIZE

Author:

zoly

Constructor Summary

Constructors

Constructor and Description
QuantizedAccumulator(Object measuredEntity, String description, String unitOfMeasurement, int factor, int lowerMagnitude, int higherMagnitude, int quantasPerMagnitude) Create a quantized accumulator.

Method Summary

Modifier and Type	Method and Description
MeasurementAccumulator	aggregate(MeasurementAccumulator mSource)
QuantizedAccumulator	createClone()
MeasurementAccumulator	createLike(Object entity)
long[]	get()
MeasurementsInfo	getInfo()
long	getMaxMeasurement()
long	getMeasurementCount()
long	getMeasurementTotal()
long	getMinMeasurement()
long[]	getQuatizedMeasurements()
long[]	getThenReset()
String	getUnitOfMeasurement()
void	record(long measurement) record a measurement for current time.
QuantizedAccumulator	reset() reset this entity.
String	toString()

Methods inherited from class org.spf4j.perf.impl.AbstractMeasurementAccumulator

getMaxTime, getMinTime, recordAt

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.spf4j.perf.MeasurementAccumulator

getCompositeData

Constructor Detail

QuantizedAccumulator

public QuantizedAccumulator(Object measuredEntity,
                            String description,
                            String unitOfMeasurement,
                            int factor,
                            int lowerMagnitude,
                            int higherMagnitude,
                            int quantasPerMagnitude)

Create a quantized accumulator. factor = 10 lowMagnitude = -2 higherMagnitude = 2 quantasPerMagnitude = 10 results in -100 -90 -80 .. -10 -9 -8 .. -1 0 1 2 .. 9 10 20 30 .. 100

Parameters:

measuredEntity - - and object representing the thing we accumulate measurements for.

description - - description of the thing we accumulate measurements for.

unitOfMeasurement - - unit of measurement.

factor -

lowerMagnitude - the lower end of the quantized recording (lowerMagnitude/lowerMagnitude) * factor ^ |lowerMagnitude|

higherMagnitude - the higher end of the quantized recording (higherMagnitude/higherMagnitude) * factor ^ |higherMagnitude|

quantasPerMagnitude - number of buckets / magnitude

Method Detail

getUnitOfMeasurement

public String getUnitOfMeasurement()

record

public void record(long measurement)

Description copied from interface: MeasurementRecorder

record a measurement for current time. System.currentTimeMillis().

Parameters:

measurement - the measurement value

get

@Nullable
public long[] get()

getInfo

public MeasurementsInfo getInfo()

aggregate

public MeasurementAccumulator aggregate(MeasurementAccumulator mSource)

createClone

public QuantizedAccumulator createClone()

reset

@Nullable
public QuantizedAccumulator reset()

Description copied from interface: MeasurementAccumulator

reset this entity.

Returns:

a clone of the object prior to reset or null if no measurements have been made.

toString

public String toString()

Overrides:

toString in class Object

getMaxMeasurement

public long getMaxMeasurement()

getMeasurementCount

public long getMeasurementCount()

getMeasurementTotal

public long getMeasurementTotal()

getMinMeasurement

public long getMinMeasurement()

getQuatizedMeasurements

public long[] getQuatizedMeasurements()

createLike

public MeasurementAccumulator createLike(Object entity)

getThenReset

@Nullable
public long[] getThenReset()

Returns:

null when no measurements have been made.