tsdb.remote

Class ServerTsDB

java.lang.Object

tsdb.remote.ServerTsDB

All Implemented Interfaces:

java.rmi.Remote, RemoteTsDB

public class ServerTsDB
extends java.lang.Object
implements RemoteTsDB

Local implementation of RemoteTsDB

Constructor Summary

Constructors

Constructor and Description
ServerTsDB(TsDB tsdb)

Method Summary

Modifier and Type	Method and Description
TimestampSeries	cache(java.lang.String streamName, java.lang.String[] columnNames, AggregationInterval aggregationInterval)
java.lang.String[]	cacheStorageGetStreamNames()
void	clearData()
Pair<java.lang.Boolean,java.lang.String[]>	console_comand_get_output(long commandThreadId)
long	execute_console_command(java.lang.String input_line)
java.lang.String	get_tubedb_version()
java.lang.String[]	getBaseSchema(java.lang.String[] rawSchema)
java.lang.String[]	getCacheSchemaNames(java.lang.String streamName)
java.lang.String[]	getGeneralStationLongNames(java.lang.String regionName)
GeneralStationInfo[]	getGeneralStations()
GeneralStationInfo[]	getGeneralStationsOfRegion(java.lang.String regionName)
java.lang.String[]	getInternalStoredStationNames()
LoggerType	getLoggerType(java.lang.String loggerTypeName)
LoggerType[]	getLoggerTypes()
java.lang.String[]	getPlotIDsByGeneralStationByLongName(java.lang.String longName)
PlotInfo[]	getPlots()
java.lang.String[]	getPlotStations(java.lang.String plotID)
java.util.ArrayList<PlotStatus>	getPlotStatuses()
java.util.ArrayList<PlotStatus>	getPlotStatusesOfGeneralStation(java.lang.String generalStationName)
java.util.ArrayList<PlotStatus>	getPlotStatusesOfRegion(java.lang.String regionName)
java.util.ArrayList<TimestampInterval<java.lang.String>>	getPlotTimeSpans()
java.util.ArrayList<TimestampInterval<java.lang.String>>	getPlotTimeSpansOfGeneralStation(java.lang.String generalStationName)
java.util.ArrayList<TimestampInterval<java.lang.String>>	getPlotTimeSpansOfRegion(java.lang.String regionName)
Region	getRegionByLongName(java.lang.String longName)
Region	getRegionByName(java.lang.String name)
Region	getRegionByPlot(java.lang.String plotID)
java.lang.String[]	getRegionLongNames()
Region[]	getRegions()
Sensor	getSensor(java.lang.String sensorName)
java.lang.String[]	getSensorNamesOfGeneralStationWithVirtual(java.lang.String generalStationName)
java.lang.String[]	getSensorNamesOfPlotWithVirtual(java.lang.String plotID) plotID format: for plot or virtual plot: PLOT_ID for virtual plot of one station: PLOT_ID:STATION_ID for one station: STATION_ID
Sensor[]	getSensors()
SourceEntry[]	getSourceCatalogEntries()
java.lang.String	getStationLoggerTypeName(java.lang.String stationName)
java.lang.String[]	getStationNames()
StationInfo[]	getStations()
TimeSeriesMask	getTimeSeriesMask(java.lang.String stationName, java.lang.String sensorName)
java.lang.String[]	getValidSchema(java.lang.String plotID, java.lang.String[] sensorNames)
java.lang.String[]	getValidSchemaWithVirtualSensors(java.lang.String plotID, java.lang.String[] sensorNames)
VirtualPlotInfo	getVirtualPlot(java.lang.String plotID)
VirtualPlotInfo[]	getVirtualPlots()
void	insertDataRows(java.lang.String stationName, java.lang.String[] sensorNames, java.util.Collection<DataRow> dataRows)
void	insertOneValue(java.lang.String stationName, java.lang.String sensorName, int timestamp, float value)
void	insertSourceCatalogEntry(SourceEntry sourceEntry)
TimestampSeries	plot(java.lang.String queryType, java.lang.String plotID, java.lang.String[] columnNames, AggregationInterval aggregationInterval, DataQuality dataQuality, boolean interpolated, java.lang.Long start, java.lang.Long end)
TimestampSeries	plotQuartile(java.lang.String plotID, java.lang.String[] columnNames, AggregationInterval aggregationInterval, DataQuality dataQuality, boolean interpolated, java.lang.Long start, java.lang.Long end)
DataEntry[]	readRawData(java.lang.String stationName, java.lang.String sensorName)
TimestampSeries	readRawData(java.lang.String stationName, java.lang.String[] sensorNames)
void	setTimeSeriesMask(java.lang.String stationName, java.lang.String sensorName, TimeSeriesMask timeSeriesMask)
java.lang.String[]	supplementSchema(java.lang.String[] schema, java.lang.String[] availableSchema)

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerTsDB

public ServerTsDB(TsDB tsdb)
           throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

Method Detail

getSensorNamesOfPlotWithVirtual

public java.lang.String[] getSensorNamesOfPlotWithVirtual(java.lang.String plotID)

Description copied from interface: RemoteTsDB

plotID format:
for plot or virtual plot: PLOT_ID
for virtual plot of one station: PLOT_ID:STATION_ID
for one station: STATION_ID

Specified by:

getSensorNamesOfPlotWithVirtual in interface RemoteTsDB

getSensorNamesOfGeneralStationWithVirtual

public java.lang.String[] getSensorNamesOfGeneralStationWithVirtual(java.lang.String generalStationName)

Specified by:

getSensorNamesOfGeneralStationWithVirtual in interface RemoteTsDB

getSensors

public Sensor[] getSensors()

Specified by:

getSensors in interface RemoteTsDB

getSensor

public Sensor getSensor(java.lang.String sensorName)

Specified by:

getSensor in interface RemoteTsDB

getBaseSchema

public java.lang.String[] getBaseSchema(java.lang.String[] rawSchema)

Specified by:

getBaseSchema in interface RemoteTsDB

getCacheSchemaNames

public java.lang.String[] getCacheSchemaNames(java.lang.String streamName)

Specified by:

getCacheSchemaNames in interface RemoteTsDB

getValidSchema

public java.lang.String[] getValidSchema(java.lang.String plotID,
                                         java.lang.String[] sensorNames)

Specified by:

getValidSchema in interface RemoteTsDB

getValidSchemaWithVirtualSensors

public java.lang.String[] getValidSchemaWithVirtualSensors(java.lang.String plotID,
                                                           java.lang.String[] sensorNames)

Specified by:

getValidSchemaWithVirtualSensors in interface RemoteTsDB

supplementSchema

public java.lang.String[] supplementSchema(java.lang.String[] schema,
                                           java.lang.String[] availableSchema)

Specified by:

supplementSchema in interface RemoteTsDB

getRegions

public Region[] getRegions()

Specified by:

getRegions in interface RemoteTsDB

getRegionByName

public Region getRegionByName(java.lang.String name)

Specified by:

getRegionByName in interface RemoteTsDB

getRegionLongNames

public java.lang.String[] getRegionLongNames()

Specified by:

getRegionLongNames in interface RemoteTsDB

getRegionByLongName

public Region getRegionByLongName(java.lang.String longName)

Specified by:

getRegionByLongName in interface RemoteTsDB

getRegionByPlot

public Region getRegionByPlot(java.lang.String plotID)

Specified by:

getRegionByPlot in interface RemoteTsDB

getGeneralStations

public GeneralStationInfo[] getGeneralStations()

Specified by:

getGeneralStations in interface RemoteTsDB

getGeneralStationsOfRegion

public GeneralStationInfo[] getGeneralStationsOfRegion(java.lang.String regionName)

Specified by:

getGeneralStationsOfRegion in interface RemoteTsDB

getGeneralStationLongNames

public java.lang.String[] getGeneralStationLongNames(java.lang.String regionName)

Specified by:

getGeneralStationLongNames in interface RemoteTsDB

getPlots

public PlotInfo[] getPlots()

Specified by:

getPlots in interface RemoteTsDB

getStations

public StationInfo[] getStations()

Specified by:

getStations in interface RemoteTsDB

getStationLoggerTypeName

public java.lang.String getStationLoggerTypeName(java.lang.String stationName)
                                          throws java.rmi.RemoteException

Specified by:

getStationLoggerTypeName in interface RemoteTsDB

Throws:

java.rmi.RemoteException

getPlotStations

public java.lang.String[] getPlotStations(java.lang.String plotID)

Specified by:

getPlotStations in interface RemoteTsDB

getVirtualPlots

public VirtualPlotInfo[] getVirtualPlots()

Specified by:

getVirtualPlots in interface RemoteTsDB

getVirtualPlot

public VirtualPlotInfo getVirtualPlot(java.lang.String plotID)

Specified by:

getVirtualPlot in interface RemoteTsDB

getStationNames

public java.lang.String[] getStationNames()

Specified by:

getStationNames in interface RemoteTsDB

cacheStorageGetStreamNames

public java.lang.String[] cacheStorageGetStreamNames()

Specified by:

cacheStorageGetStreamNames in interface RemoteTsDB

getPlotIDsByGeneralStationByLongName

public java.lang.String[] getPlotIDsByGeneralStationByLongName(java.lang.String longName)

Specified by:

getPlotIDsByGeneralStationByLongName in interface RemoteTsDB

getPlotTimeSpans

public java.util.ArrayList<TimestampInterval<java.lang.String>> getPlotTimeSpans()

Specified by:

getPlotTimeSpans in interface RemoteTsDB

getPlotTimeSpansOfGeneralStation

public java.util.ArrayList<TimestampInterval<java.lang.String>> getPlotTimeSpansOfGeneralStation(java.lang.String generalStationName)
                                                                                          throws java.rmi.RemoteException

Specified by:

getPlotTimeSpansOfGeneralStation in interface RemoteTsDB

Throws:

java.rmi.RemoteException

getPlotTimeSpansOfRegion

public java.util.ArrayList<TimestampInterval<java.lang.String>> getPlotTimeSpansOfRegion(java.lang.String regionName)
                                                                                  throws java.rmi.RemoteException

Specified by:

getPlotTimeSpansOfRegion in interface RemoteTsDB

Throws:

java.rmi.RemoteException

getPlotStatuses

public java.util.ArrayList<PlotStatus> getPlotStatuses()

Specified by:

getPlotStatuses in interface RemoteTsDB

getPlotStatusesOfGeneralStation

public java.util.ArrayList<PlotStatus> getPlotStatusesOfGeneralStation(java.lang.String generalStationName)

Specified by:

getPlotStatusesOfGeneralStation in interface RemoteTsDB

getPlotStatusesOfRegion

public java.util.ArrayList<PlotStatus> getPlotStatusesOfRegion(java.lang.String regionName)

Specified by:

getPlotStatusesOfRegion in interface RemoteTsDB

getLoggerTypes

public LoggerType[] getLoggerTypes()

Specified by:

getLoggerTypes in interface RemoteTsDB

getLoggerType

public LoggerType getLoggerType(java.lang.String loggerTypeName)

Specified by:

getLoggerType in interface RemoteTsDB

getSourceCatalogEntries

public SourceEntry[] getSourceCatalogEntries()

Specified by:

getSourceCatalogEntries in interface RemoteTsDB

execute_console_command

public long execute_console_command(java.lang.String input_line)
                             throws java.rmi.RemoteException

Specified by:

execute_console_command in interface RemoteTsDB

Throws:

java.rmi.RemoteException

console_comand_get_output

public Pair<java.lang.Boolean,java.lang.String[]> console_comand_get_output(long commandThreadId)
                                                                     throws java.rmi.RemoteException

Specified by:

console_comand_get_output in interface RemoteTsDB

Throws:

java.rmi.RemoteException

plot

public TimestampSeries plot(java.lang.String queryType,
                            java.lang.String plotID,
                            java.lang.String[] columnNames,
                            AggregationInterval aggregationInterval,
                            DataQuality dataQuality,
                            boolean interpolated,
                            java.lang.Long start,
                            java.lang.Long end)

Specified by:

plot in interface RemoteTsDB

plotQuartile

public TimestampSeries plotQuartile(java.lang.String plotID,
                                    java.lang.String[] columnNames,
                                    AggregationInterval aggregationInterval,
                                    DataQuality dataQuality,
                                    boolean interpolated,
                                    java.lang.Long start,
                                    java.lang.Long end)

Specified by:

plotQuartile in interface RemoteTsDB

cache

public TimestampSeries cache(java.lang.String streamName,
                             java.lang.String[] columnNames,
                             AggregationInterval aggregationInterval)

Specified by:

cache in interface RemoteTsDB

getTimeSeriesMask

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

Specified by:

getTimeSeriesMask in interface RemoteTsDB

setTimeSeriesMask

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

Specified by:

setTimeSeriesMask in interface RemoteTsDB

get_tubedb_version

public java.lang.String get_tubedb_version()
                                    throws java.rmi.RemoteException

Specified by:

get_tubedb_version in interface RemoteTsDB

Throws:

java.rmi.RemoteException

clearData

public void clearData()
               throws java.rmi.RemoteException

Specified by:

clearData in interface RemoteTsDB

Throws:

java.rmi.RemoteException

insertOneValue

public void insertOneValue(java.lang.String stationName,
                           java.lang.String sensorName,
                           int timestamp,
                           float value)
                    throws java.rmi.RemoteException

Specified by:

insertOneValue in interface RemoteTsDB

Throws:

java.rmi.RemoteException

getInternalStoredStationNames

public java.lang.String[] getInternalStoredStationNames()
                                                 throws java.rmi.RemoteException

Specified by:

getInternalStoredStationNames in interface RemoteTsDB

Throws:

java.rmi.RemoteException

readRawData

public DataEntry[] readRawData(java.lang.String stationName,
                               java.lang.String sensorName)
                        throws java.rmi.RemoteException

Specified by:

readRawData in interface RemoteTsDB

Throws:

java.rmi.RemoteException

readRawData

public TimestampSeries readRawData(java.lang.String stationName,
                                   java.lang.String[] sensorNames)
                            throws java.rmi.RemoteException

Specified by:

readRawData in interface RemoteTsDB

Throws:

java.rmi.RemoteException

insertDataRows

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

Specified by:

insertDataRows in interface RemoteTsDB

Throws:

java.rmi.RemoteException

insertSourceCatalogEntry

public void insertSourceCatalogEntry(SourceEntry sourceEntry)
                              throws java.rmi.RemoteException

Specified by:

insertSourceCatalogEntry in interface RemoteTsDB

Throws:

java.rmi.RemoteException