Struct StreamJoinNode 

pub struct StreamJoinNode {
    pub left_stream: String,
    pub right_stream: String,
    pub join_type: JoinType,
    pub join_strategy: JoinStrategy,
    pub left_key_extractor: Box<dyn Fn(&StreamEvent) -> Option<String> + Send + Sync>,
    pub right_key_extractor: Box<dyn Fn(&StreamEvent) -> Option<String> + Send + Sync>,
    pub join_condition: Box<dyn Fn(&StreamEvent, &StreamEvent) -> bool + Send + Sync>,
    /* private fields */
}

Stream join node for RETE network Performs windowed joins between two streams based on join conditions

Fields

left_stream: String

Name of the left input stream

right_stream: String

Name of the right input stream

join_type: JoinType

Join type (inner, left outer, right outer, full outer)

join_strategy: JoinStrategy

Join strategy (time window, count window, session window)

left_key_extractor: Box<dyn Fn(&StreamEvent) -> Option<String> + Send + Sync>

Join key extractor for left stream

right_key_extractor: Box<dyn Fn(&StreamEvent) -> Option<String> + Send + Sync>

Join key extractor for right stream

join_condition: Box<dyn Fn(&StreamEvent, &StreamEvent) -> bool + Send + Sync>

Additional join condition predicate

Implementations

impl StreamJoinNode

pub fn new( left_stream: String, right_stream: String, join_type: JoinType, join_strategy: JoinStrategy, left_key_extractor: Box<dyn Fn(&StreamEvent) -> Option<String> + Send + Sync>, right_key_extractor: Box<dyn Fn(&StreamEvent) -> Option<String> + Send + Sync>, join_condition: Box<dyn Fn(&StreamEvent, &StreamEvent) -> bool + Send + Sync>, ) -> Self

Create a new stream join node

pub fn process_left(&mut self, event: StreamEvent) -> Vec<JoinedEvent>

Process a left stream event and produce joined events

pub fn process_right(&mut self, event: StreamEvent) -> Vec<JoinedEvent>

Process a right stream event and produce joined events

pub fn update_watermark(&mut self, new_watermark: i64) -> Vec<JoinedEvent>

Update watermark and evict old events

pub fn get_stats(&self) -> JoinNodeStats

Get buffer statistics (for monitoring and debugging)