tsdb.streamdb

Class StreamStorageStreamDB

java.lang.Object

tsdb.streamdb.StreamStorageStreamDB

All Implemented Interfaces:

StreamStorage

public class StreamStorageStreamDB
extends java.lang.Object
implements StreamStorage

Implementations of StreamStorage with StreamDB

Constructor Summary

Constructors

Constructor and Description
StreamStorageStreamDB(java.lang.String streamdbPathPrefix)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	clearMaskOfStation(java.lang.String stationName)
void	close() closes all open files and flushes pending data to disk.
void	commit()
boolean	existSensor(java.lang.String stationID, java.lang.String sensorName) Check if data of sensor exits in station.
boolean	existStation(java.lang.String stationID) Check if station exists in StreamDB.
void	getInfo()
TsIterator	getRawIterator(java.lang.String stationName, java.lang.String[] sensorNames, java.lang.Long start, java.lang.Long end)
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)
int[]	getSensorTimeInterval(java.lang.String stationName, java.lang.String sensorName)
java.util.NavigableSet<java.lang.String>	getStationNames()
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	insertDataEntryArray(java.lang.String stationName, java.lang.String sensorName, DataEntry[] dataEntries)
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	insertDataRows(java.lang.String stationName, java.lang.String[] sensorNames, java.util.Collection<DataRow> dataRows)
void	insertTimestampSeries(TimestampSeries timestampSeries)
void	removeInterval(java.lang.String stationName, int start, int end)
void	setLogging(boolean logging)
void	setTimeSeriesMask(java.lang.String stationName, java.lang.String sensorName, TimeSeriesMask timeSeriesMask, boolean commit)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamStorageStreamDB

public StreamStorageStreamDB(java.lang.String streamdbPathPrefix)

Method Detail

setLogging

public void setLogging(boolean logging)

clear

public void clear()

Specified by:

clear in interface StreamStorage

close

public void close()

Description copied from interface: StreamStorage

closes all open files and flushes pending data to disk.

Specified by:

close in interface StreamStorage

insertData

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

Description copied from interface: StreamStorage

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

Specified by:

insertData in interface StreamStorage

insertDataRows

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

Description copied from interface: StreamStorage

insert ordered list of data with time span first to last

Specified by:

insertDataRows in interface StreamStorage

getRawIterator

public TsIterator getRawIterator(java.lang.String stationName,
                                 java.lang.String[] sensorNames,
                                 java.lang.Long start,
                                 java.lang.Long end)

Specified by:

getRawIterator in interface StreamStorage

getRawSensorIterator

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

Specified by:

getRawSensorIterator in interface StreamStorage

getInfo

public void getInfo()

Specified by:

getInfo in interface StreamStorage

getStationTimeInterval

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

Specified by:

getStationTimeInterval in interface StreamStorage

getSensorTimeInterval

public int[] getSensorTimeInterval(java.lang.String stationName,
                                   java.lang.String sensorName)

getSensorNames

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

Specified by:

getSensorNames in interface StreamStorage

existStation

public boolean existStation(java.lang.String stationID)

Check if station exists in StreamDB. Station exists only if it contains time series data.

Parameters:

stationID -

Returns:

existSensor

public boolean existSensor(java.lang.String stationID,
                           java.lang.String sensorName)

Check if data of sensor exits in station. If station does not exist return false.

Parameters:

stationID -

sensorName -

Returns:

getTimeSeriesMask

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

Specified by:

getTimeSeriesMask in interface StreamStorage

setTimeSeriesMask

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

Specified by:

setTimeSeriesMask in interface StreamStorage

commit

public void commit()

Specified by:

commit in interface StreamStorage

insertTimestampSeries

public void insertTimestampSeries(TimestampSeries timestampSeries)

Specified by:

insertTimestampSeries in interface StreamStorage

insertDataRows

public void insertDataRows(java.lang.String stationName,
                           java.lang.String[] sensorNames,
                           java.util.Collection<DataRow> dataRows)

insertDataEntryArray

public void insertDataEntryArray(java.lang.String stationName,
                                 java.lang.String sensorName,
                                 DataEntry[] dataEntries)

removeInterval

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

Specified by:

removeInterval in interface StreamStorage

getStationNames

public java.util.NavigableSet<java.lang.String> getStationNames()

clearMaskOfStation

public void clearMaskOfStation(java.lang.String stationName)