public class ConnectorSink extends Connector
Sink
with any
Source
it is matched with. The Connector
provides information
concerning the Sink it represents and the data the Sink is able to process,
the ability to connect Source
s to the Sink and information about it's
connectivity.Constructor and Description |
---|
ConnectorSink(Sink sink,
DataDispatcher dispatcher)
Creates a new
ConnectorSink representing given Sink . |
Modifier and Type | Method and Description |
---|---|
protected void |
connectToOutput(java.util.concurrent.LinkedBlockingQueue<DataEntry> data,
DataDescription description)
|
DataDescription[] |
getInputDescription()
Returns represented
Sink 's DataDescription , describing
the data is able to process. |
java.lang.String |
getSinkName()
Returns the
ConnectorSink 's represented Sink's simple name. |
isConnected
protected Sink sink
public ConnectorSink(Sink sink, DataDispatcher dispatcher)
ConnectorSink
representing given Sink
. As
soon as the connector is instantiated, it is registered at the
DataDispatcher
to be connected with other SystemComponent
s.sink
- Sink
to be represented.dispatcher
- DataDispatcher
used to dispatch the Connector
.protected void connectToOutput(java.util.concurrent.LinkedBlockingQueue<DataEntry> data, DataDescription description)
data
- LinkedBlockingQueue
providing incoming data.description
- DataDescription
of incoming data.public DataDescription[] getInputDescription()
Sink
's DataDescription
, describing
the data is able to process.Sink
's DataDescription
.public java.lang.String getSinkName()
ConnectorSink
's represented Sink's simple name.Sink
's simple name.