Struct TemporalJoinTranslatorConfig 

pub struct TemporalJoinTranslatorConfig {
    pub stream_table: String,
    pub table_name: String,
    pub stream_key_column: String,
    pub table_key_column: String,
    pub stream_time_column: String,
    pub table_version_column: String,
    pub semantics: String,
    pub join_type: String,
}

Configuration for temporal join operator (FOR SYSTEM_TIME AS OF).

Fields

stream_table: String

Stream (left) side table name

table_name: String

Table (right) side table name

stream_key_column: String

Stream side key column

table_key_column: String

Table side key column

stream_time_column: String

Stream-side column for lookup timestamp (from FOR SYSTEM_TIME AS OF)

table_version_column: String

Table-side version column. Empty string = auto-detect from table schema at registration.

semantics: String

Temporal semantics: “event_time” or “process_time”

join_type: String

Join type: “inner” or “left”

Trait Implementations

impl Clone for TemporalJoinTranslatorConfig

fn clone(&self) -> TemporalJoinTranslatorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TemporalJoinTranslatorConfig

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

Formats the value using the given formatter.

impl Display for TemporalJoinTranslatorConfig

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

Formats the value using the given formatter.