Stream interconnect
Stream interconnect is a feature in Usage Engine that enables you to forward output data from one stream to be processed by another stream. With the Stream interconnect feature, you can split a complex stream that reuses a common logic into smaller, independent streams to act as transaction boundaries without risking the integrity of your entire process. See Transaction safety for more information.
The Stream interconnect feature is comprised of two functions, one which acts as a collector and the other as a forwarder.
Example - Interconnect receiver and Interconnect sender stream
As an example, you can split the Cultflicks video streaming stream into several smaller streams by using the Stream interconnect functions. Instead of one stream, you can have three streams:
The initial Cultflicks video streaming stream to generate the input data, enriching the data, and calculating the view percentage. This output data is then sent to the following smaller streams.
An Aggregate view time stream to process the aggregation of view time, classifying the users, and sending them the bill information.
A View completion check stream to process the view completion checking, which then sends the aggregated data to a billing partner or external analysts based on its completion status.
This is what the initial Cultflicks video streaming stream looks like:
This is what the Cultflicks video streaming stream could look like by using the Stream interconnect feature after separating the aggregation of view time, and completion time check processes as their own streams.
This section has the following subsections: