Enum JoinOperatorConfig 

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

Union type for join operator configurations

Variants

StreamStream(StreamJoinConfig)

Stream-stream join

Lookup(LookupJoinConfig)

Lookup join

Temporal(TemporalJoinTranslatorConfig)

Temporal join (FOR SYSTEM_TIME AS OF)

Implementations

impl JoinOperatorConfig

pub fn from_analysis(analysis: &JoinAnalysis) -> Result<Self, String>

Create from join analysis.

Errors

Returns an error when the analyzed join has no supported, complete runtime contract.

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

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

Errors

Returns an error when any join step has no supported, complete runtime contract.

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_temporal(&self) -> bool

Check if this is a temporal join.

pub fn left_keys(&self) -> &[String]

Get the ordered left-side equality key columns.

pub fn right_keys(&self) -> &[String]

Get the ordered right-side equality key columns.

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.