Stream Interconnect

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 function. The names of the collector and forwarder functions are:

• Interconnect Receiver (Collector)
• Interconnect Sender (Forwarder)

Interconnect Receiver

As mentioned above, you must create the collector stream containing an Interconnect Receiver in order to connect it to the forwarder stream containing an Interconnect Sender.

For example, consider a stream shown below containing an Interconnect Receiver, Map and Log functions. This stream acts as the Collector stream collecting incoming data from a Forwarder stream. 

The Interconnect Receiver function does not need to be configured separately but instead the name of the Collector stream must be copied to the clipboard and pasted in the configuration of the Interconnect Sender function to connect to the Forwarder stream. 

Interconnect Sender

The Interconnect Sender function is used in the Forwarder stream to forward output data to be collected by the Collector stream containing the Interconnect Receiver function.

For example, consider a stream shown below containing a Data Generator, Map and Interconnect Sender functions. This stream acts as the Forwarder stream. 

In the configuration of the Interconnect Sender, you can select the stream to which you want to forward the output data to in the Forward  data to stream option. A notification is displayed after successfully connecting the Forwarder stream to the Collector stream.