Struct JoinOptimizer 

pub struct JoinOptimizer { /* private fields */ }

Join optimizer - analyzes stream characteristics and suggests optimizations

Implementations

impl JoinOptimizer

pub fn new() -> Self

Create a new join optimizer

pub fn register_stream_stats(&mut self, stats: StreamStats)

Register stream statistics for optimization

pub fn optimize_join( &self, left_stream: &str, right_stream: &str, join_type: JoinType, join_strategy: JoinStrategy, ) -> OptimizedJoinPlan

Optimize a join plan based on stream characteristics

pub fn estimate_memory_usage( &self, left_stream: &str, right_stream: &str, window_duration: Duration, ) -> usize

Estimate memory usage for a join

pub fn recommend_window_size( &self, left_stream: &str, right_stream: &str, max_memory_bytes: usize, ) -> Duration

Recommend optimal window size based on stream characteristics

Trait Implementations

impl Default for JoinOptimizer

fn default() -> Self

Returns the “default value” for a type.