public abstract class StreamDataProvider extends Object implements ISOSDataProvider, IEventListener
Implementation of SOS data provider connecting to a streaming data source
Constructor and Description |
---|
StreamDataProvider(IDataProducerModule<?> dataSource,
StreamDataProviderConfig config,
SOSDataFilter filter) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Properly releases all resources accessed by provider
(for instance, when connection is ended by client)
|
DataEncoding |
getDefaultResultEncoding()
Requests provider to specify the preferred encoding for the
underlying data, given the current config and filter
|
IObservation |
getNextObservation()
Requests provider to generate the next observation from the
underlying data, given the current config and filter
|
DataBlock |
getNextResultRecord()
Requests provider to generate the next CDM record from the
underlying data, given the current config and filter
|
DataComponent |
getResultStructure()
Requests provider to provide the result structure corresponding
to the current config and filter
|
void |
handleEvent(Event<?> e) |
protected boolean |
isNowTimeInstant(TimeExtent timeFilter) |
public StreamDataProvider(IDataProducerModule<?> dataSource, StreamDataProviderConfig config, SOSDataFilter filter) throws ServiceException
ServiceException
protected boolean isNowTimeInstant(TimeExtent timeFilter)
public IObservation getNextObservation() throws SensorHubException
ISOSDataProvider
getNextObservation
in interface ISOSDataProvider
SensorHubException
public DataBlock getNextResultRecord()
ISOSDataProvider
getNextResultRecord
in interface ISOSDataProvider
public DataComponent getResultStructure()
ISOSDataProvider
getResultStructure
in interface ISOSDataProvider
public DataEncoding getDefaultResultEncoding()
ISOSDataProvider
getDefaultResultEncoding
in interface ISOSDataProvider
public void handleEvent(Event<?> e)
handleEvent
in interface IEventListener
public void close()
ISOSDataProvider
close
in interface ISOSDataProvider
Copyright © 2016 Sensia Software LLC. All rights reserved.