Module stream_beta_node 

Stream Beta Node - Multi-Stream Join Processing

Handles joins between multiple stream patterns in RETE network. Correlates events from different streams based on join conditions.

Supports:

• Two-stream joins: moisture && temp
• Three+ stream joins: moisture && temp && weather (nested beta nodes)

Example:

moisture: MoistureSensor from stream("moisture-sensors") over window(5 min, sliding) &&
temp: TemperatureSensor from stream("temperature-sensors") over window(5 min, sliding) &&
moisture.zone_id == temp.zone_id

Structs

BetaNodeStats

JoinCondition

Join condition between two streams

JoinedStreamEvent

Result of a successful join

MultiStreamJoinResult

Result of multi-stream join (supports 2+ streams)

StreamBetaNode

Beta node for joining two streams (or stream + joined result) Supports nested joins for 3+ stream correlation

Enums

BetaInput

Input to a beta node - can be either an alpha node or another beta node This enables nested beta nodes for 3+ stream joins

JoinOperator

JoinStrategy

Join strategy