Struct JoinAnalysis 

pub struct JoinAnalysis {

    pub join_type: JoinType,
    pub left_table: String,
    pub right_table: String,
    pub left_key_column: String,
    pub right_key_column: String,
    pub time_bound: Option<Duration>,
    pub is_lookup_join: bool,
    pub left_alias: Option<String>,
    pub right_alias: Option<String>,
    pub is_asof_join: bool,
    pub asof_direction: Option<AsofSqlDirection>,
    pub left_time_column: Option<String>,
    pub right_time_column: Option<String>,
    pub asof_tolerance: Option<Duration>,
    pub is_temporal_join: bool,
    pub temporal_version_column: Option<String>,
    pub additional_key_columns: Vec<(String, String)>,
}

Analysis result for a JOIN clause

Fields

join_type: JoinType

Type of join (inner, left, right, full)

left_table: String

Left side table name

right_table: String

Right side table name

left_key_column: String

Left side key column

right_key_column: String

Right side key column

time_bound: Option<Duration>

Time bound for stream-stream joins (None for lookup joins)

is_lookup_join: bool

Whether this is a lookup join (no time bound)

left_alias: Option<String>

Left side alias (if any)

right_alias: Option<String>

Right side alias (if any)

is_asof_join: bool

Whether this is an ASOF join

asof_direction: Option<AsofSqlDirection>

ASOF join direction (Backward or Forward)

left_time_column: Option<String>

Left side time column for ASOF join

right_time_column: Option<String>

Right side time column for ASOF join

asof_tolerance: Option<Duration>

ASOF join tolerance (max time difference)

is_temporal_join: bool

Whether this is a temporal join (FOR SYSTEM_TIME AS OF)

temporal_version_column: Option<String>

The version column from FOR SYSTEM_TIME AS OF (e.g., order_time)

additional_key_columns: Vec<(String, String)>

Additional key columns for composite join keys (beyond the primary key pair)

Implementations

impl JoinAnalysis

pub fn stream_stream( left_table: String, right_table: String, left_key: String, right_key: String, time_bound: Duration, join_type: JoinType, ) -> Self

Create a stream-stream join analysis

pub fn lookup( left_table: String, right_table: String, left_key: String, right_key: String, join_type: JoinType, ) -> Self

Create a lookup join analysis

pub fn asof( left_table: String, right_table: String, left_key: String, right_key: String, direction: AsofSqlDirection, left_time_col: String, right_time_col: String, tolerance: Option<Duration>, ) -> Self

Create an ASOF join analysis

pub fn temporal( left_table: String, right_table: String, left_key: String, right_key: String, version_column: String, join_type: JoinType, ) -> Self

Create a temporal join analysis (FOR SYSTEM_TIME AS OF).

pub fn is_bounded(&self) -> bool

True if this step has any kind of temporal bound — a BETWEEN-derived time bound, ASOF match condition, or FOR SYSTEM_TIME AS OF.

Trait Implementations

impl Clone for JoinAnalysis

fn clone(&self) -> JoinAnalysis

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JoinAnalysis

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

Formats the value using the given formatter.