tsdb.streamdb

Interface StreamStorage

All Known Implementing Classes:

StreamStorageStreamDB

public interface StreamStorage

This class encapsulates StreamDB and provides basic methods to store and query time series data.

Method Summary

Modifier and Type	Method and Description
void	clear()
void	close() closes all open files and flushes pending data to disk.
void	commit()
void	getInfo()
TsIterator	getRawIterator(java.lang.String stationName, java.lang.String[] sensorNames, java.lang.Long minTimestamp, java.lang.Long maxTimestamp)
StreamIterator	getRawSensorIterator(java.lang.String stationName, java.lang.String sensorName, java.lang.Long start, java.lang.Long end)
java.lang.String[]	getSensorNames(java.lang.String stationName)
long[]	getStationTimeInterval(java.lang.String streamName)
TimeSeriesMask	getTimeSeriesMask(java.lang.String stationName, java.lang.String sensorName)
void	insertData(java.lang.String streamName, java.util.TreeMap<java.lang.Long,DataRow> eventMap, java.lang.String[] sensorNames) Saves new data on disk.
void	insertDataRows(java.lang.String streamName, java.util.List<DataRow> eventList, long first, long last, java.lang.String[] sensorNames) insert ordered list of data with time span first to last
void	insertTimestampSeries(TimestampSeries timestampSeries)
void	removeInterval(java.lang.String stationName, int start, int end)
void	setTimeSeriesMask(java.lang.String stationName, java.lang.String sensorName, TimeSeriesMask timeSeriesMask, boolean commit)

Method Detail

clear

void clear()

close

void close()

closes all open files and flushes pending data to disk.

insertData

void insertData(java.lang.String streamName,
                java.util.TreeMap<java.lang.Long,DataRow> eventMap,
                java.lang.String[] sensorNames)

Saves new data on disk. If some timestamps exist already in database, no data is overwritten.

Parameters:

streamName -

eventMap -

sensorNames -

insertDataRows

void insertDataRows(java.lang.String streamName,
                    java.util.List<DataRow> eventList,
                    long first,
                    long last,
                    java.lang.String[] sensorNames)

insert ordered list of data with time span first to last

Parameters:

streamName -

eventList -

first -

last -

sensorNames -

getRawIterator

TsIterator getRawIterator(java.lang.String stationName,
                          java.lang.String[] sensorNames,
                          java.lang.Long minTimestamp,
                          java.lang.Long maxTimestamp)

getInfo

void getInfo()

getStationTimeInterval

long[] getStationTimeInterval(java.lang.String streamName)

getSensorNames

java.lang.String[] getSensorNames(java.lang.String stationName)

getRawSensorIterator

StreamIterator getRawSensorIterator(java.lang.String stationName,
                                    java.lang.String sensorName,
                                    java.lang.Long start,
                                    java.lang.Long end)

getTimeSeriesMask

TimeSeriesMask getTimeSeriesMask(java.lang.String stationName,
                                 java.lang.String sensorName)

setTimeSeriesMask

void setTimeSeriesMask(java.lang.String stationName,
                       java.lang.String sensorName,
                       TimeSeriesMask timeSeriesMask,
                       boolean commit)

insertTimestampSeries

void insertTimestampSeries(TimestampSeries timestampSeries)

removeInterval

void removeInterval(java.lang.String stationName,
                    int start,
                    int end)

commit

void commit()