Modifier and Type | Method and Description |
---|---|
DataBlock |
DataBlock.clone() |
DataBlock |
DataBlock.copy() |
DataBlock |
DataComponent.createDataBlock()
Create a new datablock for holding data of this component
|
DataBlock |
DataComponent.getData()
Get the datablock associated to this component
|
DataBlock |
DataBlock.renew() |
Modifier and Type | Method and Description |
---|---|
void |
DataComponent.setData(DataBlock dataBlock)
Assign a new datablock to this component.
|
Modifier and Type | Field and Description |
---|---|
protected DataBlock[] |
DataEvent.records
New data that triggered this event.
Multiple records can be associated to a single event because with high rate producers, it is often not practical to generate an event for every single record of measurements. |
Modifier and Type | Method and Description |
---|---|
DataBlock |
IStreamingDataInterface.getLatestRecord()
Gets the latest record received on this data channel.
|
DataBlock[] |
DataEvent.getRecords() |
Constructor and Description |
---|
DataEvent(long timeStamp,
IStreamingDataInterface dataInterface,
DataBlock... records)
Constructs a data event with no related entity
|
DataEvent(long timeStamp,
String entityID,
IStreamingDataInterface dataInterface,
DataBlock... records)
Constructs a data event associated to an identifiable entity
|
Modifier and Type | Method and Description |
---|---|
DataBlock |
IDataRecord.getData() |
DataBlock |
IBasicStorage.getDataBlock(DataKey key)
Retrieves raw data block with the specified key
|
Modifier and Type | Method and Description |
---|---|
Iterator<DataBlock> |
IBasicStorage.getDataBlockIterator(IDataFilter filter)
Gets iterator of raw data blocks matching the specified filter
|
Modifier and Type | Method and Description |
---|---|
void |
IBasicStorage.storeRecord(DataKey key,
DataBlock data)
Persists data block in storage
|
void |
IBasicStorage.updateRecord(DataKey key,
DataBlock data)
Updates record with specified key with new data
|
Modifier and Type | Method and Description |
---|---|
void |
IOnDemandProcessInstance.execute(DataBlock paramValues,
Map<String,IDataFilter> dataFilters)
Executes the process synchronously with the given set of parameters and data filters
|
Modifier and Type | Method and Description |
---|---|
DataBlock |
ISensorDataInterface.getLatestRecord()
Gets the latest record received on this data channel.
|
Modifier and Type | Method and Description |
---|---|
List<DataBlock> |
ISensorDataInterface.getAllRecords(boolean clear)
Retrieves all records stored by the driver or sensor.
This method must be implemented if ISensorDataInterface.isStorageSupported() returns true. |
List<DataBlock> |
ISensorDataInterface.getLatestRecords(int maxRecords,
boolean clear)
Retrieves the N last records stored.
This method must be implemented if ISensorDataInterface.isStorageSupported() returns true. |
Modifier and Type | Method and Description |
---|---|
CommandStatus |
ISensorControlInterface.execCommand(DataBlock command)
Executes the command synchronously, blocking until completion of command
|
CommandStatus |
ISensorControlInterface.scheduleCommand(DataBlock command,
DateTime execTime)
Schedules a command to be executed asynchronously at the specified time
|
CommandStatus |
ISensorControlInterface.sendCommand(DataBlock command)
Sends a command that will be executed asynchronously
|
Modifier and Type | Method and Description |
---|---|
CommandStatus |
ISensorControlInterface.execCommandGroup(List<DataBlock> commands)
Executes multiple commands synchronously and in the order specified.
|
CommandStatus |
ISensorControlInterface.scheduleCommandGroup(List<DataBlock> commands,
DateTime execTime)
Schedules a group of commands to be executed asynchronously at the specified time.
|
CommandStatus |
ISensorControlInterface.sendCommandGroup(List<DataBlock> commands)
Sends a group of commands for asynchronous execution.
|
Constructor and Description |
---|
SensorDataEvent(long timeStamp,
ISensorDataInterface dataInterface,
DataBlock... records)
Constructs an event for data produced by an isolated sensor.
The sensor ID is obtained from the sensor description of the parent sensor module. |
SensorDataEvent(long timeStamp,
String sensorID,
IStreamingDataInterface dataInterface,
DataBlock... records)
Constructs an event for data produced by the specified sensor.
This flavor is used to identify a particular sensor within a network. |
Modifier and Type | Method and Description |
---|---|
void |
SOSClient.SOSRecordListener.newRecord(DataBlock data) |
Modifier and Type | Method and Description |
---|---|
SubmitResponse |
SPSClient.sendTaskMessage(DataBlock data) |
Modifier and Type | Method and Description |
---|---|
DataBlock |
InMemoryBasicStorage.getDataBlock(DataKey key) |
DataBlock |
InMemoryBasicStorage.TimeSeriesImpl.getDataBlock(DataKey key) |
DataBlock |
GenericStreamStorage.getDataBlock(DataKey key) |
Modifier and Type | Method and Description |
---|---|
Iterator<DataBlock> |
InMemoryBasicStorage.getDataBlockIterator(IDataFilter filter) |
Iterator<DataBlock> |
InMemoryBasicStorage.TimeSeriesImpl.getDataBlockIterator(IDataFilter filter) |
Iterator<DataBlock> |
GenericStreamStorage.getDataBlockIterator(IDataFilter filter) |
Modifier and Type | Method and Description |
---|---|
DataKey |
InMemoryBasicStorage.TimeSeriesImpl.store(DataKey key,
DataBlock data) |
void |
InMemoryBasicStorage.storeRecord(DataKey key,
DataBlock data) |
void |
GenericStreamStorage.storeRecord(DataKey key,
DataBlock data) |
void |
InMemoryBasicStorage.TimeSeriesImpl.update(DataKey key,
DataBlock data) |
void |
InMemoryBasicStorage.updateRecord(DataKey key,
DataBlock data) |
void |
GenericStreamStorage.updateRecord(DataKey key,
DataBlock data) |
Modifier and Type | Method and Description |
---|---|
DataBlock |
BasicStorageImpl.getDataBlock(DataKey key) |
Modifier and Type | Method and Description |
---|---|
Iterator<DataBlock> |
BasicStorageImpl.getDataBlockIterator(IDataFilter filter) |
Modifier and Type | Method and Description |
---|---|
void |
BasicStorageImpl.storeRecord(DataKey key,
DataBlock data) |
void |
BasicStorageImpl.updateRecord(DataKey key,
DataBlock data) |
Modifier and Type | Field and Description |
---|---|
protected DataBlock |
AbstractSensorOutput.latestRecord |
Modifier and Type | Method and Description |
---|---|
DataBlock |
AbstractSensorOutput.getLatestRecord() |
Modifier and Type | Method and Description |
---|---|
List<DataBlock> |
AbstractSensorOutput.getAllRecords(boolean clear) |
List<DataBlock> |
AbstractSensorOutput.getLatestRecords(int maxRecords,
boolean clear) |
Modifier and Type | Method and Description |
---|---|
CommandStatus |
AbstractSensorControl.scheduleCommand(DataBlock command,
DateTime execTime) |
CommandStatus |
AbstractSensorControl.sendCommand(DataBlock command) |
Modifier and Type | Method and Description |
---|---|
CommandStatus |
AbstractSensorControl.execCommandGroup(List<DataBlock> commands) |
CommandStatus |
AbstractSensorControl.scheduleCommandGroup(List<DataBlock> commands,
DateTime execTime) |
CommandStatus |
AbstractSensorControl.sendCommandGroup(List<DataBlock> commands) |
Modifier and Type | Method and Description |
---|---|
void |
SOSVirtualSensor.newResultRecord(String templateID,
DataBlock... dataBlocks) |
void |
SOSVirtualSensorOutput.publishNewRecord(DataBlock dataBlock) |
Modifier and Type | Method and Description |
---|---|
CommandStatus |
SWEVirtualSensorControl.execCommand(DataBlock command) |
void |
SWEVirtualSensorOutput.publishNewRecord(DataBlock dataBlock) |
Modifier and Type | Method and Description |
---|---|
DataBlock |
ISOSDataProvider.getNextResultRecord()
Requests provider to generate the next CDM record from the
underlying data, given the current config and filter
|
DataBlock |
StreamDataProvider.getNextResultRecord() |
DataBlock |
StorageDataProvider.getNextResultRecord() |
Modifier and Type | Method and Description |
---|---|
void |
SensorDataConsumer.newResultRecord(String templateID,
DataBlock... dataBlocks) |
void |
ISOSDataConsumer.newResultRecord(String templateID,
DataBlock... datablocks)
Requests consumer to process a list of new result records
|
Modifier and Type | Method and Description |
---|---|
void |
ISPSConnector.sendSubmitData(ITask task,
DataBlock data)
Sends the command data through the connector
|
void |
SharedSensorConnector.sendSubmitData(ITask task,
DataBlock data) |
void |
DirectSensorConnector.sendSubmitData(ITask task,
DataBlock data) |
Modifier and Type | Method and Description |
---|---|
DataBlock |
IDataProvider.getNextDataBlock() |
DataBlock |
DataStreamParser.parseNextBlock() |
Modifier and Type | Method and Description |
---|---|
void |
DataHandler.endData(DataComponent info,
DataBlock data) |
void |
DataHandler.endDataAtom(DataComponent info,
DataBlock data) |
void |
DataHandler.endDataBlock(DataComponent info,
DataBlock data) |
void |
IDataConsumer.pushNextDataBlock(DataBlock dataBlock) |
void |
DataStreamWriter.write(DataBlock data) |
Modifier and Type | Field and Description |
---|---|
protected DataBlock |
CommonImageIODecoder.imageBlock |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDataBlock |
class |
DataBlockBoolean
Carries an array of boolean primitives.
|
class |
DataBlockByte
Carries an array of byte primitives.
|
class |
DataBlockCompressed
Carries data in compressed format.
|
class |
DataBlockDouble
Carries an array of double primitives.
|
class |
DataBlockFloat
Carries an array of float primitives.
|
class |
DataBlockInt
Carries an array of int primitives.
|
class |
DataBlockList
Uses the composite pattern to hold a list of child DataBlocks.
|
class |
DataBlockLong
Carries an array of long primitives.
|
class |
DataBlockMixed
Uses the composite pattern to carry a fixed size array
of mixed types DataBlocks.
|
class |
DataBlockParallel
Uses the composite pattern to carry a fixed size array
of parallel array DataBlocks.
|
class |
DataBlockShort
Carries an array of short primitives.
|
class |
DataBlockString
Carries an array of String objects.
|
class |
DataBlockTuple
Uses the composite pattern to carry a fixed size array
of mixed types DataBlocks.
|
class |
DataBlockUByte
Carries an array of byte primitives.
|
class |
DataBlockUInt
Carries an array of int primitives.
|
class |
DataBlockUShort
Carries an array of short primitives.
|
Modifier and Type | Field and Description |
---|---|
protected DataBlock |
DataBlockCompressed.uncompressedData |
Modifier and Type | Field and Description |
---|---|
protected ListIterator<DataBlock> |
DataList.blockIterator |
protected List<DataBlock> |
DataBlockList.blockList |
Modifier and Type | Method and Description |
---|---|
static DataBlock |
DataBlockFactory.createBlock(DataType dataType) |
DataBlock |
DataBlockList.get(int blockIndex) |
DataBlock |
AbstractDataComponentImpl.getData() |
DataBlock |
DataList.nextDataBlock() |
Modifier and Type | Method and Description |
---|---|
ListIterator<DataBlock> |
DataBlockList.blockIterator() |
List<DataBlock> |
DataBlockList.getUnderlyingObject() |
Modifier and Type | Method and Description |
---|---|
void |
DataBlockList.add(DataBlock block) |
void |
DataList.addData(DataBlock dataBlock) |
void |
VarSizeMapper.mapData(DataBlock data) |
void |
DataVisitor.mapData(DataBlock data) |
void |
DataBlockList.set(int blockIndex,
DataBlock block) |
void |
DataChoiceImpl.setData(DataBlock dataBlock) |
void |
AbstractRecordImpl.setData(DataBlock dataBlock) |
abstract void |
AbstractDataComponentImpl.setData(DataBlock dataBlock) |
void |
DataValue.setData(DataBlock dataBlock) |
void |
DataArrayImpl.setData(DataBlock dataBlock) |
void |
AbstractRangeComponentImpl.setData(DataBlock dataBlock) |
void |
DataList.setData(DataBlock dataBlock) |
Modifier and Type | Method and Description |
---|---|
void |
DataBlockList.setUnderlyingObject(List<DataBlock> blockList) |
Modifier and Type | Method and Description |
---|---|
DataBlock |
BufferedObservationSeries.getNextDataBlock() |
Modifier and Type | Method and Description |
---|---|
void |
BufferedObservationSeries.pushNextDataBlock(DataBlock dataBlock) |
Modifier and Type | Field and Description |
---|---|
protected LinkedList<DataBlock> |
DataQueue.queue |
Modifier and Type | Method and Description |
---|---|
DataBlock |
DataQueue.get()
Default version of previous method with timeout set to 0
This will make us wait until a new value arrives on the queue
|
DataBlock |
DataQueue.get(long timeout)
Gets the first DataBlock from the queue
|
Modifier and Type | Method and Description |
---|---|
void |
DataQueue.add(DataBlock data)
Adds DataBlock at the end of the list
|
Modifier and Type | Method and Description |
---|---|
DataBlock |
SWEData.getNextDataBlock() |
DataBlock |
BinaryDataParser.parse() |
DataBlock |
AbstractDataParser.parseNextBlock()
Parse next atom from stream
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultWriterHandler.endData(DataComponent info,
DataBlock data) |
void |
DefaultParserHandler.endData(DataComponent info,
DataBlock data) |
void |
DefaultWriterHandler.endDataAtom(DataComponent info,
DataBlock data) |
void |
DefaultParserHandler.endDataAtom(DataComponent info,
DataBlock data) |
void |
DefaultWriterHandler.endDataBlock(DataComponent info,
DataBlock data) |
void |
DefaultParserHandler.endDataBlock(DataComponent info,
DataBlock data) |
boolean |
ScalarIndexer.getBooleanValue(DataBlock dataBlk) |
byte |
ScalarIndexer.getByteValue(DataBlock dataBlk) |
int |
ScalarIndexer.getDataIndex(DataBlock dataBlk) |
double |
ScalarIndexer.getDoubleValue(DataBlock dataBlk) |
float |
ScalarIndexer.getFloatValue(DataBlock dataBlk) |
int |
ScalarIndexer.getIntValue(DataBlock dataBlk) |
long |
ScalarIndexer.getLongValue(DataBlock dataBlk) |
short |
ScalarIndexer.getShortValue(DataBlock dataBlk) |
String |
ScalarIndexer.getStringValue(DataBlock dataBlk) |
void |
SWEData.pushNextDataBlock(DataBlock dataBlock) |
void |
XmlDataWriterDOM.write(DataBlock data) |
void |
AbstractDataWriter.write(DataBlock dataBlock) |
Copyright © 2016 Sensia Software LLC. All rights reserved.