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(File databaseFile)

Method Summary

Modifier and Type	Method and Description
long	alocateMeasurements(MeasurementsInfo measurement, int sampleTimeMillis) Make any allocations necessary for the following measurements.
void	close()
void	flush() flush all data that might be buffered by this store.
TSDBWriter	getDBWriter()
String	getTableAsCsv(String tableName)
String[]	getTables()
void	saveMeasurements(long tableId, long timeStampMillis, 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(File databaseFile)
                     throws IOException

Throws:

IOException

Method Detail

alocateMeasurements

public long alocateMeasurements(MeasurementsInfo measurement,
                                int sampleTimeMillis)
                         throws IOException

Description copied from interface: MeasurementStore

Make any allocations necessary for the following measurements.

Specified by:

alocateMeasurements in interface MeasurementStore

Parameters:

measurement - - the information about the measurement(s)

sampleTimeMillis - - the expected sample time. (interval between the stored measurements).

Returns:

- the id of the measurementInfo table.

Throws:

IOException - - IO issues.

saveMeasurements

public void saveMeasurements(long tableId,
                             long timeStampMillis,
                             long... measurements)
                      throws IOException

Description copied from interface: MeasurementStore

Save measurements.

Specified by:

saveMeasurements in interface MeasurementStore

Parameters:

tableId - - the table ID to store measurements for.

timeStampMillis - - the timestamp of the measurement (millis since Jan 1 1970 UTC)

measurements - - the measurements to persist. (same order as declared)

Throws:

IOException - - IO issues.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

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 - - IO issues.

getTables

public String[] getTables()
                   throws IOException

Throws:

IOException

getTableAsCsv

public String getTableAsCsv(String tableName)
                     throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

getDBWriter

public TSDBWriter getDBWriter()