public class ObsStorageImpl extends BasicStorageImpl implements IObsStorageModule<BasicStorageConfig>
PERST implementation of IObsStorage
for storing observations.
autoCommit, db, dbRoot
config, eventHandler, lastError, logger, securityHandler, startRequested, state, stateLock, statusMsg
Constructor and Description |
---|
ObsStorageImpl() |
Modifier and Type | Method and Description |
---|---|
void |
addRecordStore(String name,
DataComponent recordStructure,
DataEncoding recommendedEncoding)
Adds a data store for a new record type in this storage
|
protected org.garret.perst.Persistent |
createRoot(org.garret.perst.Storage db) |
Iterator<String> |
getFoiIDs(IFoiFilter filter)
Gets IDs of FOIs matching the filter
|
Iterator<AbstractFeature> |
getFois(IFoiFilter filter)
Retrieves features of interest matching the given filter
|
Bbox |
getFoisSpatialExtent()
Gets the bounding rectangle of all features of interest contained
in this storage
|
int |
getNumFois(IFoiFilter filter)
Gets the number of features of interest matching the filter
|
void |
storeFoi(String producerID,
AbstractFeature foi)
Stores a new feature of interest description into storage.
|
backup, cleanup, commit, getDataBlock, getDataBlockIterator, getDataSourceDescriptionAtTime, getDataSourceDescriptionHistory, getLatestDataSourceDescription, getNumMatchingRecords, getNumRecords, getRecordIterator, getRecordsTimeClusters, getRecordsTimeRange, getRecordStores, removeDataSourceDescription, removeDataSourceDescriptionHistory, removeRecord, removeRecords, restore, rollback, start, stop, storeDataSourceDescription, storeRecord, sync, updateDataSourceDescription, updateRecord
canInit, canStart, canStop, clearError, clearStatus, getConfiguration, getCurrentError, getCurrentState, getLocalID, getLogger, getName, getStatusMessage, init, init, isInitialized, isStarted, loadState, notifyConnectionStatus, registerListener, reportError, reportError, reportStatus, requestInit, requestStart, requestStop, saveState, setConfiguration, setState, toString, unregisterListener, updateConfig, waitForState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
backup, commit, restore, rollback, sync
cleanup, getConfiguration, getCurrentError, getCurrentState, getLocalID, getName, getStatusMessage, init, init, isInitialized, isStarted, loadState, registerListener, requestInit, requestStart, requestStop, saveState, setConfiguration, start, stop, unregisterListener, updateConfig, waitForState
getDataBlock, getDataBlockIterator, getDataSourceDescriptionAtTime, getDataSourceDescriptionHistory, getLatestDataSourceDescription, getNumMatchingRecords, getNumRecords, getRecordIterator, getRecordsTimeClusters, getRecordsTimeRange, getRecordStores, removeDataSourceDescription, removeDataSourceDescriptionHistory, removeRecord, removeRecords, storeDataSourceDescription, storeRecord, updateDataSourceDescription, updateRecord
protected org.garret.perst.Persistent createRoot(org.garret.perst.Storage db)
createRoot
in class BasicStorageImpl
public final int getNumFois(IFoiFilter filter)
IObsStorage
getNumFois
in interface IObsStorage
filter
- filtering criteriaspublic Bbox getFoisSpatialExtent()
IObsStorage
getFoisSpatialExtent
in interface IObsStorage
public final Iterator<String> getFoiIDs(IFoiFilter filter)
IObsStorage
getFoiIDs
in interface IObsStorage
filter
- filtering criteriaspublic Iterator<AbstractFeature> getFois(IFoiFilter filter)
IObsStorage
getFois
in interface IObsStorage
filter
- filtering criteriaspublic void storeFoi(String producerID, AbstractFeature foi)
IObsStorage
storeFoi
in interface IObsStorage
producerID
- ID of producer by which this FOI has been observedfoi
- feature object to storepublic void addRecordStore(String name, DataComponent recordStructure, DataEncoding recommendedEncoding)
IBasicStorage
addRecordStore
in interface IBasicStorage
addRecordStore
in class BasicStorageImpl
name
- name of record type (should match output name of the data source)recordStructure
- SWE data component describing the record structurerecommendedEncoding
- recommended encoding for this record typeCopyright © 2016 Sensia Software LLC. All rights reserved.