tsdb.streamdb

Class StreamDB

java.lang.Object

tsdb.streamdb.StreamDB

public class StreamDB
extends java.lang.Object

Central class of StreamDB

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	clear() delete all content in db
void	clearMaskOfStation(java.lang.String stationName)
void	close() write all data to disk and close db
void	commit() write all data to disk
void	compact()
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.
protected void	finalize()
<any>	getSensorChunkMetaMap(SensorMeta sensorMeta)
StreamIterator	getSensorIterator(SensorMeta sensorMeta, int minTimestamp, int maxTimestamp)
StreamIterator	getSensorIterator(StationMeta stationMeta, java.lang.String sensorName, int minTimestamp, int maxTimestamp)
StreamIterator	getSensorIterator(java.lang.String stationName, java.lang.String sensorName, int minTimestamp, int maxTimestamp)
<any>	getSensorMap(StationMeta stationMeta)
<any>	getSensorMap(java.lang.String stationName)
SensorMeta	getSensorMeta(java.lang.String stationName, java.lang.String sensorName)
java.util.NavigableSet<java.lang.String>	getSensorNames(java.lang.String stationName)
int[]	getSensorTimeInterval(SensorMeta sensorMeta)
int[]	getSensorTimeInterval(java.lang.String stationName, java.lang.String sensorName)
TimeSeriesMask	getSensorTimeSeriesMask(StationMeta stationMeta, java.lang.String sensorName, boolean createIfNotExists)
TimeSeriesMask	getSensorTimeSeriesMask(java.lang.String stationName, java.lang.String sensorName, boolean createIfNotExists)
StreamTsIterator	getSensorTsIterator(java.lang.String stationName, java.lang.String sensorName, int minTimestamp, int maxTimestamp)
java.util.NavigableSet<java.lang.String>	getStationNames()
int[]	getStationTimeInterval(java.lang.String stationName)
TsIterator	getTsIterator(java.lang.String stationName, java.lang.String[] sensorNames, int minTimestamp, int maxTimestamp)
void	insertSensorData(java.lang.String stationName, java.lang.String sensorName, DataEntry[] data)
void	printStatistics()
void	removeInterval(java.lang.String stationName, int start, int end)
void	removeSensorData(java.lang.String stationName, java.lang.String sensorName, int start, int end)
void	setSensorTimeSeriesMask(java.lang.String stationName, java.lang.String sensorName, TimeSeriesMask timeSeriesMask)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamDB

public StreamDB(java.lang.String streamdbPathPrefix)

Method Detail

commit

public void commit()

write all data to disk

close

public void close()

write all data to disk and close db

clear

public void clear()

delete all content in db

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

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:

getSensorMeta

public SensorMeta getSensorMeta(java.lang.String stationName,
                                java.lang.String sensorName)

getSensorTimeSeriesMask

public TimeSeriesMask getSensorTimeSeriesMask(StationMeta stationMeta,
                                              java.lang.String sensorName,
                                              boolean createIfNotExists)

getSensorTimeSeriesMask

public TimeSeriesMask getSensorTimeSeriesMask(java.lang.String stationName,
                                              java.lang.String sensorName,
                                              boolean createIfNotExists)

setSensorTimeSeriesMask

public void setSensorTimeSeriesMask(java.lang.String stationName,
                                    java.lang.String sensorName,
                                    TimeSeriesMask timeSeriesMask)

getSensorChunkMetaMap

public <any> getSensorChunkMetaMap(SensorMeta sensorMeta)

insertSensorData

public void insertSensorData(java.lang.String stationName,
                             java.lang.String sensorName,
                             DataEntry[] data)

removeSensorData

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

getStationNames

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

getSensorNames

public java.util.NavigableSet<java.lang.String> getSensorNames(java.lang.String stationName)

getSensorIterator

public StreamIterator getSensorIterator(java.lang.String stationName,
                                        java.lang.String sensorName,
                                        int minTimestamp,
                                        int maxTimestamp)

getSensorIterator

public StreamIterator getSensorIterator(StationMeta stationMeta,
                                        java.lang.String sensorName,
                                        int minTimestamp,
                                        int maxTimestamp)

getSensorIterator

public StreamIterator getSensorIterator(SensorMeta sensorMeta,
                                        int minTimestamp,
                                        int maxTimestamp)

getSensorTsIterator

public StreamTsIterator getSensorTsIterator(java.lang.String stationName,
                                            java.lang.String sensorName,
                                            int minTimestamp,
                                            int maxTimestamp)

getTsIterator

public TsIterator getTsIterator(java.lang.String stationName,
                                java.lang.String[] sensorNames,
                                int minTimestamp,
                                int maxTimestamp)

getSensorMap

public <any> getSensorMap(StationMeta stationMeta)

getSensorMap

public <any> getSensorMap(java.lang.String stationName)

getSensorTimeInterval

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

getSensorTimeInterval

public int[] getSensorTimeInterval(SensorMeta sensorMeta)

getStationTimeInterval

public int[] getStationTimeInterval(java.lang.String stationName)

printStatistics

public void printStatistics()

compact

public void compact()

removeInterval

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

clearMaskOfStation

public void clearMaskOfStation(java.lang.String stationName)