org.spf4j.perf.impl.ms.tsdb

Class TSDBMeasurementStore

java.lang.Object

org.spf4j.perf.impl.ms.tsdb.TSDBMeasurementStore

All Implemented Interfaces:

Closeable, AutoCloseable, MeasurementStore

@ThreadSafe
public final class TSDBMeasurementStore
extends Object
implements MeasurementStore

Author:

zoly

Constructor Summary

Constructors

Constructor and Description
TSDBMeasurementStore(String databaseName)

Method Summary

Methods

Modifier and Type	Method and Description
void	alocateMeasurements(EntityMeasurementsInfo measurement, int sampleTimeMillis) Make any allocations necessary for the following measurements.
static boolean	canGenerateCount(TSTable info)
static boolean	canGenerateHeatChart(TSTable info)
static boolean	canGenerateMinMaxAvgCount(TSTable info)
void	close()
void	flush() flush all data that might be buffered by this store.
List<String>	generateCharts(int width, int height)
List<String>	generateCharts(long startTimeMillis, long endTimeMillis, int width, int height) Quantized recorders will have min, max avg charts and distribution charts generated.
static boolean	isCounterOnly(TSTable info)
void	saveMeasurements(EntityMeasurementsInfo measurementInfo, long timeStampMillis, int sampleTimeMillis, long... measurements) Save measurements.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TSDBMeasurementStore

public TSDBMeasurementStore(String databaseName)
                     throws IOException

Throws:

IOException

Method Detail

alocateMeasurements

public void alocateMeasurements(EntityMeasurementsInfo measurement,
                       int sampleTimeMillis)
                         throws IOException

Description copied from interface: MeasurementStore

Make any allocations necessary for the following measurements.

Specified by:

alocateMeasurements in interface MeasurementStore

Throws:

IOException

saveMeasurements

public void saveMeasurements(EntityMeasurementsInfo measurementInfo,
                    long timeStampMillis,
                    int sampleTimeMillis,
                    long... measurements)
                      throws IOException

Description copied from interface: MeasurementStore

Save measurements.

Specified by:

saveMeasurements in interface MeasurementStore

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

generateCharts

public List<String> generateCharts(int width,
                          int height)
                            throws IOException

Throws:

IOException

generateCharts

public List<String> generateCharts(long startTimeMillis,
                          long endTimeMillis,
                          int width,
                          int height)
                            throws IOException

Quantized recorders will have min, max avg charts and distribution charts generated. Counting recorders will have simple charts generated.

Parameters:

startTimeMillis -

endTimeMillis -

width -

height -

Returns:

Throws:

IOException

isCounterOnly

public static boolean isCounterOnly(TSTable info)

canGenerateMinMaxAvgCount

public static boolean canGenerateMinMaxAvgCount(TSTable info)

canGenerateCount

public static boolean canGenerateCount(TSTable info)

canGenerateHeatChart

public static boolean canGenerateHeatChart(TSTable info)

flush

public void flush()
           throws IOException

Description copied from interface: MeasurementStore

flush all data that might be buffered by this store.

Specified by:

flush in interface MeasurementStore

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object