Struct StreamJoinManager 

pub struct StreamJoinManager { /* private fields */ }

Manages multiple stream joins and coordinates event routing

Implementations

impl StreamJoinManager

pub fn new() -> Self

Create a new stream join manager

pub fn register_join( &mut self, join_id: String, join_node: StreamJoinNode, result_handler: Box<dyn Fn(JoinedEvent) + Send + Sync>, )

Register a new stream join

pub fn unregister_join(&mut self, join_id: &str)

Remove a stream join

pub fn process_event(&self, event: StreamEvent)

Process an incoming stream event Routes the event to all relevant join nodes

pub fn update_watermark(&self, stream_id: &str, watermark: i64)

Update watermark for a specific stream This triggers eviction of old events and emission of outer join results

pub fn get_all_stats(&self) -> HashMap<String, JoinNodeStats>

Get statistics for all joins

pub fn get_join_stats(&self, join_id: &str) -> Option<JoinNodeStats>

Get statistics for a specific join

pub fn clear(&mut self)

Clear all joins (for testing or reset)

Trait Implementations

impl Default for StreamJoinManager

fn default() -> Self

Returns the “default value” for a type.