public interface Sink
DataDescription
describing the
data the source is able to process and a ConnectorSink
to connect
with.receiveData(LinkedBlockingQueue, DataDescription)
is provided, which enables the sink to receive data via
LinkedBlockingQueue
s.Modifier and Type | Method and Description |
---|---|
DataDescription[] |
getInputDescription()
Returns a
DataDescription describing the data, the Sink is able
to process. |
ConnectorSink |
getSinkConnector()
Returns the
Sink 's ConnectorSink . |
void |
receiveData(java.util.concurrent.LinkedBlockingQueue<DataEntry> data,
DataDescription description)
Sets a
LinkedBlockingQueue of DataEntry s to receive data
with. |
void receiveData(java.util.concurrent.LinkedBlockingQueue<DataEntry> data, DataDescription description)
LinkedBlockingQueue
of DataEntry
s to receive data
with. Can be called multiple times if the Sink is matched with multiple
Source
s.data
- LinkedBlockingQueue
to receive DataEntry
s
with.description
- DataDescription
describing incoming data for given
queue.ConnectorSink getSinkConnector()
Sink
's ConnectorSink
.Sink
's ConnectorSink
.DataDescription[] getInputDescription()
DataDescription
describing the data, the Sink
is able
to process.DataDescription
describing the data, the Sink
is able to
process.