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 left_time_column: Option<String>,
    pub right_time_column: Option<String>,
    pub temporal_probe_schedule: Option<TemporalProbeSchedule>,
    pub temporal_probe_alias: 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)

left_time_column: Option<String>

Left side time column for a bounded join

right_time_column: Option<String>

Right side time column for a bounded join

temporal_probe_schedule: Option<TemporalProbeSchedule>

Target-time schedule for a temporal join.

temporal_probe_alias: Option<String>

Pseudo-table alias exposing offset_ms and probe_time for multi-horizon probes.

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 temporal( left_table: String, right_table: String, left_key: String, right_key: String, left_time_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 a BETWEEN bound or FOR SYSTEM_TIME AS OF.

pub fn is_temporal_join(&self) -> bool

Whether this step uses versioned event-time lookup state.

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.

impl Eq for JoinAnalysis

impl PartialEq for JoinAnalysis

fn eq(&self, other: &JoinAnalysis) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for JoinAnalysis