Inner stream joins

Strict join between two event streams

Objective

To perform a strict join between two event streams, an inner join is used.

This join operator emits an event only when a successful match occurs between streams. Otherwise, it waits until the join criteria are met, as determined by the configured policy settings.

Uses

Among the previously mentioned examples in the stream join concept page, the application for inner joins can impact the following:

1. Immediate feedback loop It enables businesses to receive immediate feedback on customer behaviour, allowing for rapid adjustments to marketing strategies.

2. Enhanced customer experience By understanding which ads are clicked by which customers, businesses can personalise experiences and improve overall engagement.

Example

Inner joins are set by ==.

streams join:
  expression: "sitevisits.customerId == webpage.adclicks.customerId"
  merge events: true
  left policy:
    time to live: 30 minutes
  right policy:
    delete on join: true