Struct StreamJoinConfig 

pub struct StreamJoinConfig {
    pub left_key_column: String,
    pub right_key_column: String,
    pub time_bound_ms: i64,
    pub join_type: JoinType,
    pub operator_id: Option<String>,
    pub row_encoding: JoinRowEncoding,
    pub asymmetric_compaction: bool,
    pub idle_threshold_ms: i64,
    pub per_key_tracking: bool,
    pub key_idle_threshold_ms: i64,
    pub build_side_pruning: bool,
    pub build_side: Option<JoinSide>,
}

Configuration for stream-stream joins (F057).

Provides fine-grained control over join behavior and optimizations. Use the builder pattern for convenient construction.

Example

use laminar_core::operator::stream_join::{StreamJoinConfig, JoinType, JoinRowEncoding};
use std::time::Duration;

let config = StreamJoinConfig::builder()
    .left_key_column("order_id")
    .right_key_column("order_id")
    .time_bound(Duration::from_secs(3600))
    .join_type(JoinType::Inner)
    .row_encoding(JoinRowEncoding::CpuFriendly)
    .build();

Fields

left_key_column: String

Left stream key column name.

right_key_column: String

Right stream key column name.

time_bound_ms: i64

Time bound for matching (milliseconds).

join_type: JoinType

Type of join to perform.

operator_id: Option<String>

Operator ID for checkpointing.

row_encoding: JoinRowEncoding

Row encoding strategy.

asymmetric_compaction: bool

Enable asymmetric compaction optimization.

idle_threshold_ms: i64

Threshold for considering a side “finished” (ms).

per_key_tracking: bool

Enable per-key cleanup tracking.

key_idle_threshold_ms: i64

Threshold for idle key cleanup (ms).

build_side_pruning: bool

Enable build-side pruning.

build_side: Option<JoinSide>

Which side to use as build side (None = auto-select based on statistics).

Implementations

impl StreamJoinConfig

pub fn builder() -> StreamJoinConfigBuilder

Creates a new configuration builder.

Trait Implementations

impl Clone for StreamJoinConfig

fn clone(&self) -> StreamJoinConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamJoinConfig

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

Formats the value using the given formatter.

impl Default for StreamJoinConfig

fn default() -> Self

Returns the “default value” for a type.