Modifier and Type | Method and Description |
---|---|
protected void |
ProcessorSlidingMean.processData(DataEntry entry) |
Modifier and Type | Method and Description |
---|---|
void |
DataViewer.draw(DataEntry data)
Draws given
DataEntry to every component that can display it. |
protected void |
SinkDataViewer.processData(DataEntry entry) |
Modifier and Type | Class and Description |
---|---|
class |
DataViewer<DataType extends DataEntry>
Is able to draw data of type DataType, representing any
DataEntry , in a particular way. |
Modifier and Type | Class and Description |
---|---|
class |
ChartDataViewer<DataType extends DataEntry>
Generic SWT-Composite able to display data as a chart-diagram.
|
Modifier and Type | Method and Description |
---|---|
protected void |
SinkUnisensLogger.processData(DataEntry entry) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
NetworkProtocol.getMessageFor(DataEntry data)
Generates an xml-element to transmit given
DataEntry . |
protected void |
SinkUnisensStreamer.processData(DataEntry entry) |
void |
StreamingClient.rweceiveData(DataEntry entry)
|
void |
StreamingServer.send(DataEntry data)
Sends a
DataEntry to all registered StreamingClient s. |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractProcessor.processData(DataEntry data)
Passes a
DataEntry to the AbstractProcessor which needs
to be processed. |
protected abstract void |
AbstractSink.processData(DataEntry entry)
Passes a
DataEntry to the AbstractSink , which needs to be
processed. |
protected void |
AbstractSource.writeOutput(DataEntry entry)
Offers data to all dispatched
Sink s. |
Modifier and Type | Method and Description |
---|---|
void |
AbstractProcessor.receiveData(java.util.concurrent.LinkedBlockingQueue<DataEntry> data,
DataDescription description) |
void |
AbstractSink.receiveData(java.util.concurrent.LinkedBlockingQueue<DataEntry> data,
DataDescription description) |
void |
Sink.receiveData(java.util.concurrent.LinkedBlockingQueue<DataEntry> data,
DataDescription description)
Sets a
LinkedBlockingQueue of DataEntry s to receive data
with. |
Modifier and Type | Class and Description |
---|---|
class |
DataEvent
A DataEvent is the internal representation of a
EventEntry as
specified in the Unisens specification: "EventEntry represents an Entry containing a list of Events. |
class |
DataSignal
A DataSignal is the internal representation of a SignalEntry as specified in
the
Unisens specification:"A SignalEntry represents continuously sampled data with a fixed sample rate" A DataSignal holds a single sample of data that consists of 1 or more channels. |
class |
DataValue
A DataValue is the internal representation of a ValuesEntry as specified in
the
Unisens specification:"A ValuesEntry represents data acquired at certain points in time. |
Modifier and Type | Method and Description |
---|---|
void |
ReceiverQueues.add(DataEntry e)
Adds data to the data-queues.
|
void |
ReceiverQueues.put(DataEntry e)
Puts data to the data-queues.
|
Modifier and Type | Method and Description |
---|---|
void |
ReceiverQueues.addReceiver(java.util.concurrent.LinkedBlockingQueue<DataEntry> receiver)
Adds another
LinkedBlockingQueue to the list of receivers. |
Constructor and Description |
---|
ReceiverQueues(java.util.Vector<java.util.concurrent.LinkedBlockingQueue<DataEntry>> receivers)
Constructs the
ReceiverQueues by setting up all the connection
between the incoming data and the provided list of receivers. |
Modifier and Type | Method and Description |
---|---|
void |
ConnectorSource.writeOutput(DataEntry entry)
Passes data to every registered
Sink . |
Modifier and Type | Method and Description |
---|---|
void |
ConnectorSource.AnnotatedReceiverQueues.addReceiver(java.util.concurrent.LinkedBlockingQueue<DataEntry> queues)
Adds a new
LinkedBlockingQueue to the ReceiverQueues 's queue-pool. |
protected void |
ConnectorSource.connectToInput(java.util.concurrent.LinkedBlockingQueue<DataEntry> newQueue,
DataDescription description)
Connects the represented
Source to a LinkedBlockingQueue
to write data to. |
protected void |
ConnectorSink.connectToOutput(java.util.concurrent.LinkedBlockingQueue<DataEntry> data,
DataDescription description)
|