Stream Interconnect is a feature in that enables output data from one stream to be used as the input for a second stream. This feature can help a user avoid the complexity of having large streams with complex business logic and have flexibility in reusing streams with a common logic. The Stream Interconnect feature comprises a Forwarder function and a Collector functionof two functions, one which acts as a collector and the other as a forwarder. The names of the collector and forwarder functions are:
- Interconnect Receiver (Collector)
- Interconnect Sender (Forwarder)
...
...
Interconnect
...
Interconnect Receiver
...
Receiver
The Interconnect Receiver function is used to collect data that is forwarded by an Interconnect Sender from another stream.
For example, consider a stream shown below containing an Interconnect Receiver, Map and Log functions. This stream collects incoming data from a stream that sends output data using an Interconnect Sender.
...
The Interconnect Sender function is used to forward output data to be collected by the stream containing the an Interconnect Receiver functionfrom another stream.
For example, consider a stream shown below containing a Data Generator, Map and Interconnect Sender functions. This stream forwards output data to an Interconnect Receiver present in a different stream.
...