Struct TemporalProbeConfig 

pub struct TemporalProbeConfig {
    pub left_table: String,
    pub right_table: String,
    pub left_alias: Option<String>,
    pub right_alias: Option<String>,
    pub key_columns: Vec<String>,
    pub left_time_column: String,
    pub right_time_column: String,
    pub expanded_offsets_ms: Vec<i64>,
    pub probe_alias: String,
}

Configuration for the temporal probe join operator.

Fields

left_table: String

right_table: String

left_alias: Option<String>

right_alias: Option<String>

key_columns: Vec<String>

left_time_column: String

right_time_column: String

expanded_offsets_ms: Vec<i64>

Sorted, deduplicated offsets in milliseconds.

probe_alias: String

Probe pseudo-table alias (the AS p in the SQL).

Implementations

impl TemporalProbeConfig

pub fn new( left_table: String, right_table: String, left_alias: Option<String>, right_alias: Option<String>, key_columns: Vec<String>, left_time_column: String, right_time_column: String, offsets: &ProbeOffsetSpec, probe_alias: String, ) -> Self

Create a new config, expanding offsets immediately.

pub fn max_offset_ms(&self) -> i64

Maximum offset in milliseconds.

pub fn min_offset_ms(&self) -> i64

Minimum offset in milliseconds. Negative means look-back.

Trait Implementations

impl Clone for TemporalProbeConfig

fn clone(&self) -> TemporalProbeConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TemporalProbeConfig

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

Formats the value using the given formatter.

impl Display for TemporalProbeConfig

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

Formats the value using the given formatter.