org.spf4j.perf.impl

Class RecorderFactory

java.lang.Object

org.spf4j.perf.impl.RecorderFactory

public final class RecorderFactory
extends Object

Author:

zoly

Field Summary

Fields

Modifier and Type	Field and Description
static MeasurementStore	MEASUREMENT_STORE

Method Summary

Modifier and Type	Method and Description
static MeasurementRecorder	createDirectGraphiteTcpRecorder(Object forWhat, String unitOfMeasurement, String graphiteHost, int graphitePort)
static MeasurementRecorder	createDirectGraphiteUdpRecorder(Object forWhat, String unitOfMeasurement, String graphiteHost, int graphitePort)
static MeasurementRecorder	createDirectRecorder(Object forWhat, String unitOfMeasurement)
static MeasurementRecorder	createDirectRecorder(Object forWhat, String unitOfMeasurement, int sampleTimeMillis)
static MultiMeasurementRecorder	createDirectRecorder(Object measuredEntity, String description, String[] measurementNames, String[] measurementUnits)
static MeasurementRecorderSource	createDirectRecorderSource(Object forWhat, String unitOfMeasurement)
static MeasurementRecorder	createScalableCountingRecorder(Object forWhat, String unitOfMeasurement, int sampleTimeMillis)
static MeasurementRecorderSource	createScalableCountingRecorderSource(Object forWhat, String unitOfMeasurement, int sampleTimeMillis)
static CloseableMeasurementRecorderSource	createScalableCountingRecorderSource2(Object forWhat, String unitOfMeasurement, int sampleTimeMillis)
static MeasurementRecorder	createScalableMinMaxAvgRecorder(Object forWhat, String unitOfMeasurement, int sampleTimeMillis)
static CloseableMeasurementRecorder	createScalableMinMaxAvgRecorder2(Object forWhat, String unitOfMeasurement, int sampleTimeMillis)
static MeasurementRecorderSource	createScalableMinMaxAvgRecorderSource(Object forWhat, String unitOfMeasurement, int sampleTimeMillis)
static MeasurementRecorder	createScalableQuantizedRecorder(Object forWhat, String unitOfMeasurement, int sampleTimeMillis, int factor, int lowerMagnitude, int higherMagnitude, int quantasPerMagnitude) Create a Quantized Measurement recorder.
static CloseableMeasurementRecorder	createScalableQuantizedRecorder2(Object forWhat, String unitOfMeasurement, int sampleTimeMillis, int factor, int lowerMagnitude, int higherMagnitude, int quantasPerMagnitude)
static MeasurementRecorderSource	createScalableQuantizedRecorderSource(Object forWhat, String unitOfMeasurement, int sampleTimeMillis, int factor, int lowerMagnitude, int higherMagnitude, int quantasPerMagnitude)
static CloseableMeasurementRecorderSource	createScalableQuantizedRecorderSource2(Object forWhat, String unitOfMeasurement, int sampleTimeMillis, int factor, int lowerMagnitude, int higherMagnitude, int quantasPerMagnitude)
static MeasurementStore	fromString(String string)
static MeasurementStore	getMeasurementStore()

Methods inherited from class java.lang.Object

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

Field Detail

MEASUREMENT_STORE

public static final MeasurementStore MEASUREMENT_STORE

Method Detail

getMeasurementStore

public static MeasurementStore getMeasurementStore()

fromString

public static MeasurementStore fromString(String string)
                                   throws IOException,
                                          ObjectCreationException

Throws:

IOException

ObjectCreationException

createScalableQuantizedRecorder

public static MeasurementRecorder createScalableQuantizedRecorder(Object forWhat,
                                                                  String unitOfMeasurement,
                                                                  int sampleTimeMillis,
                                                                  int factor,
                                                                  int lowerMagnitude,
                                                                  int higherMagnitude,
                                                                  int quantasPerMagnitude)

Create a Quantized Measurement recorder. (see concept at http://dtrace.org/blogs/bmc/2011/02/08/llquantize/ ) A quantized measurement recorder is appropriate for low overhead measurement recording with good detail using quantized data resolution. For lower overhead recorder see createScalableMinMaxAvgRecorder. example : createScalableQuantizedRecorder("response time", "ms", 60000, 10, -3, 3, 5) will aggregate and persist measurements every minute. will have the following measurement buckets: QNI_-1000, Q-1000_-800, Q-800_-600, Q-600_-400, Q-400_-100, Q-100_-80, Q-80_-60, Q-60_-40, Q-40_-10, Q-10_-8, Q-8_-6, Q-6_-4, Q-4_-2, Q-2_0, Q0_2, Q2_4, Q4_6, Q6_8, Q8_10, Q10_40, Q40_60, Q60_80, Q80_100, Q100_400, Q400_600, Q600_800, Q800_1000, Q1000_PI where A_B equivalent Math notation is [A,B) where NI = negative infinity where PI is positive infinity

Parameters:

forWhat - an object identifying what is being measured, ex: "response time"

unitOfMeasurement - the unit of measurement of the measurements, ex "milliseconds"

sampleTimeMillis - the sampling (accumulating interval) ex: 60000 for minute level detail.

factor - the log factor of the magnitudes, ex: 10 for 0-1,1-10,10-100,100 - 1000 magnitudes.

lowerMagnitude - the lowest magnitude. ex: 10 for 10 * factor min bucket limit value.

higherMagnitude - th highest magnitude. ex 10 for 10 * factor max bucket limit value.

quantasPerMagnitude - number of equally divided measurement buckets per magnitude. ex: 10

Returns:

a measurement recorder that

createScalableQuantizedRecorder2

public static CloseableMeasurementRecorder createScalableQuantizedRecorder2(Object forWhat,
                                                                            String unitOfMeasurement,
                                                                            int sampleTimeMillis,
                                                                            int factor,
                                                                            int lowerMagnitude,
                                                                            int higherMagnitude,
                                                                            int quantasPerMagnitude)

createScalableCountingRecorder

public static MeasurementRecorder createScalableCountingRecorder(Object forWhat,
                                                                 String unitOfMeasurement,
                                                                 int sampleTimeMillis)

createScalableMinMaxAvgRecorder

public static MeasurementRecorder createScalableMinMaxAvgRecorder(Object forWhat,
                                                                  String unitOfMeasurement,
                                                                  int sampleTimeMillis)

createScalableMinMaxAvgRecorder2

public static CloseableMeasurementRecorder createScalableMinMaxAvgRecorder2(Object forWhat,
                                                                            String unitOfMeasurement,
                                                                            int sampleTimeMillis)

createScalableQuantizedRecorderSource

public static MeasurementRecorderSource createScalableQuantizedRecorderSource(Object forWhat,
                                                                              String unitOfMeasurement,
                                                                              int sampleTimeMillis,
                                                                              int factor,
                                                                              int lowerMagnitude,
                                                                              int higherMagnitude,
                                                                              int quantasPerMagnitude)

createScalableQuantizedRecorderSource2

public static CloseableMeasurementRecorderSource createScalableQuantizedRecorderSource2(Object forWhat,
                                                                                        String unitOfMeasurement,
                                                                                        int sampleTimeMillis,
                                                                                        int factor,
                                                                                        int lowerMagnitude,
                                                                                        int higherMagnitude,
                                                                                        int quantasPerMagnitude)

createScalableCountingRecorderSource

public static MeasurementRecorderSource createScalableCountingRecorderSource(Object forWhat,
                                                                             String unitOfMeasurement,
                                                                             int sampleTimeMillis)

createScalableCountingRecorderSource2

public static CloseableMeasurementRecorderSource createScalableCountingRecorderSource2(Object forWhat,
                                                                                       String unitOfMeasurement,
                                                                                       int sampleTimeMillis)

createScalableMinMaxAvgRecorderSource

public static MeasurementRecorderSource createScalableMinMaxAvgRecorderSource(Object forWhat,
                                                                              String unitOfMeasurement,
                                                                              int sampleTimeMillis)

createDirectRecorder

public static MultiMeasurementRecorder createDirectRecorder(Object measuredEntity,
                                                            String description,
                                                            String[] measurementNames,
                                                            String[] measurementUnits)

createDirectRecorder

public static MeasurementRecorder createDirectRecorder(Object forWhat,
                                                       String unitOfMeasurement)

createDirectRecorder

public static MeasurementRecorder createDirectRecorder(Object forWhat,
                                                       String unitOfMeasurement,
                                                       int sampleTimeMillis)

createDirectRecorderSource

public static MeasurementRecorderSource createDirectRecorderSource(Object forWhat,
                                                                   String unitOfMeasurement)

createDirectGraphiteUdpRecorder

public static MeasurementRecorder createDirectGraphiteUdpRecorder(Object forWhat,
                                                                  String unitOfMeasurement,
                                                                  String graphiteHost,
                                                                  int graphitePort)
                                                           throws ObjectCreationException

Throws:

ObjectCreationException

createDirectGraphiteTcpRecorder

public static MeasurementRecorder createDirectGraphiteTcpRecorder(Object forWhat,
                                                                  String unitOfMeasurement,
                                                                  String graphiteHost,
                                                                  int graphitePort)
                                                           throws ObjectCreationException

Throws:

ObjectCreationException