Struct AsofJoinConfig 

pub struct AsofJoinConfig {
    pub key_column: String,
    pub left_time_column: String,
    pub right_time_column: String,
    pub direction: AsofDirection,
    pub tolerance: Option<Duration>,
    pub join_type: AsofJoinType,
    pub operator_id: Option<String>,
}

Configuration for an ASOF join operator.

Fields

key_column: String

Column name used as the join key (must match in both streams).

left_time_column: String

Column name for the timestamp in left stream events.

right_time_column: String

Column name for the timestamp in right stream events.

direction: AsofDirection

Direction for temporal matching.

tolerance: Option<Duration>

Maximum time difference for matching (None = unlimited).

join_type: AsofJoinType

Type of join to perform.

operator_id: Option<String>

Operator ID for checkpointing.

Implementations

impl AsofJoinConfig

pub fn builder() -> AsofJoinConfigBuilder

Creates a new builder for ASOF join configuration.

pub fn tolerance_ms(&self) -> i64

Returns the tolerance in milliseconds, or i64::MAX if unlimited.

Trait Implementations

impl Clone for AsofJoinConfig

fn clone(&self) -> AsofJoinConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AsofJoinConfig

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

Formats the value using the given formatter.