Struct StreamBetaNode 

pub struct StreamBetaNode {
    pub name: String,
    pub left_input: BetaInput,
    pub right_input: BetaInput,
    pub join_conditions: Vec<JoinCondition>,
    pub strategy: JoinStrategy,
    /* private fields */
}

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

Fields

name: String

Name for debugging

left_input: BetaInput

Left input (alpha node or nested beta node)

right_input: BetaInput

Right input (alpha node or nested beta node)

join_conditions: Vec<JoinCondition>

Join conditions (e.g., zone_id == zone_id)

strategy: JoinStrategy

Join strategy

Implementations

impl StreamBetaNode

pub fn new( name: String, left_input: BetaInput, right_input: BetaInput, join_conditions: Vec<JoinCondition>, strategy: JoinStrategy, ) -> Self

Create a new beta node for stream join

pub fn from_alpha_nodes( name: String, left_alpha: Arc<Mutex<StreamAlphaNode>>, right_alpha: Arc<Mutex<StreamAlphaNode>>, join_conditions: Vec<JoinCondition>, strategy: JoinStrategy, ) -> Self

Create beta node from two alpha nodes (simple 2-stream join)

pub fn from_beta_and_alpha( name: String, left_beta: Arc<Mutex<StreamBetaNode>>, right_alpha: Arc<Mutex<StreamAlphaNode>>, join_conditions: Vec<JoinCondition>, strategy: JoinStrategy, ) -> Self

Create beta node for nested join (beta + alpha)

pub fn process_left_event( &mut self, event: StreamEvent, ) -> Vec<MultiStreamJoinResult>

Process event from left input (wrap in MultiStreamJoinResult)

pub fn process_right_event( &mut self, event: StreamEvent, ) -> Vec<MultiStreamJoinResult>

Process event from right input (wrap in MultiStreamJoinResult)

pub fn process_left_result( &mut self, result: MultiStreamJoinResult, ) -> Vec<MultiStreamJoinResult>

Process join result from left input (for nested beta nodes)

pub fn process_right_result( &mut self, result: MultiStreamJoinResult, ) -> Vec<MultiStreamJoinResult>

Process join result from right input (for nested beta nodes)

pub fn get_stats(&self) -> BetaNodeStats

Get statistics about buffer sizes

Trait Implementations

impl Debug for StreamBetaNode

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.