org.spf4j.perf

Interface MeasurementStore

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

GraphiteTcpStore, GraphiteUdpStore, MultiStore, NopMeasurementStore, TSDBMeasurementStore, TSDBTxtMeasurementStore

public interface MeasurementStore
extends Closeable

A measurement store.

Author:

zoly

Method Summary

Modifier and Type	Method and Description
long	alocateMeasurements(MeasurementsInfo measurementInfo, int sampleTimeMillis) Make any allocations necessary for the following measurements.
void	flush() flush all data that might be buffered by this store.
void	saveMeasurements(long tableId, long timeStampMillis, long... measurements) Save measurements.

Methods inherited from interface java.io.Closeable

close

Method Detail

alocateMeasurements

long alocateMeasurements(MeasurementsInfo measurementInfo,
                         int sampleTimeMillis)
                  throws IOException

Make any allocations necessary for the following measurements.

Parameters:

measurementInfo - - 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

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

Save measurements.

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.

flush

void flush()
    throws IOException

flush all data that might be buffered by this store.

Throws:

IOException - - IO issues.