Struct TemporalJoinConfig 

pub struct TemporalJoinConfig {
    pub time_tolerance: Duration,
    pub max_buffer_size: usize,
    pub mode: JoinMode,
}

Configuration for the temporal stream joiner.

Fields

time_tolerance: Duration

Maximum time difference between left and right events for a match (used by Inner and LeftOuter modes).

max_buffer_size: usize

Maximum number of events to buffer per stream before eviction.

mode: JoinMode

Join semantics.

Trait Implementations

impl Clone for TemporalJoinConfig

fn clone(&self) -> TemporalJoinConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TemporalJoinConfig

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

Formats the value using the given formatter.

impl Default for TemporalJoinConfig

fn default() -> Self

Returns the “default value” for a type.