Enum JoinOperatorConfig 

pub enum JoinOperatorConfig {
    StreamStream(StreamJoinConfig),
    Lookup(LookupJoinConfig),
    Asof(AsofJoinTranslatorConfig),
    Temporal(TemporalJoinTranslatorConfig),
}

Union type for join operator configurations

Variants

StreamStream(StreamJoinConfig)

Stream-stream join

Lookup(LookupJoinConfig)

Lookup join

Asof(AsofJoinTranslatorConfig)

ASOF join

Temporal(TemporalJoinTranslatorConfig)

Temporal join (FOR SYSTEM_TIME AS OF)

Implementations

impl JoinOperatorConfig

pub fn from_analysis(analysis: &JoinAnalysis) -> Self

Create from join analysis.

pub fn from_multi_analysis(multi: &MultiJoinAnalysis) -> Vec<Self>

Create from a multi-join analysis, producing one config per join step.

pub fn is_stream_stream(&self) -> bool

Check if this is a stream-stream join.

pub fn is_lookup(&self) -> bool

Check if this is a lookup join.

pub fn is_asof(&self) -> bool

Check if this is an ASOF join.

pub fn is_temporal(&self) -> bool

Check if this is a temporal join.

pub fn left_key(&self) -> &str

Get the left key column name.

pub fn right_key(&self) -> &str

Get the right key column name.

Trait Implementations

impl Clone for JoinOperatorConfig

fn clone(&self) -> JoinOperatorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JoinOperatorConfig

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

Formats the value using the given formatter.

impl Display for JoinOperatorConfig

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

Formats the value using the given formatter.