Struct TemporalJoinConfig 

pub struct TemporalJoinConfig {
    pub stream_key_column: String,
    pub table_key_column: String,
    pub table_version_column: String,
    pub semantics: TemporalJoinSemantics,
    pub table_characteristics: TableCharacteristics,
    pub join_type: TemporalJoinType,
    pub operator_id: Option<String>,
    pub max_versions_per_key: usize,
}

Configuration for a temporal join operator.

Fields

stream_key_column: String

Column name in the stream to use as lookup key.

table_key_column: String

Column name in the table that matches the stream key.

table_version_column: String

Column name for the version timestamp in the table.

semantics: TemporalJoinSemantics

Join semantics (event-time or process-time).

table_characteristics: TableCharacteristics

Table characteristics (append-only or non-append-only).

join_type: TemporalJoinType

Type of join to perform.

operator_id: Option<String>

Operator ID for checkpointing.

max_versions_per_key: usize

Maximum number of versions to retain per key (0 = unlimited).

Implementations

impl TemporalJoinConfig

pub fn builder() -> TemporalJoinConfigBuilder

Creates a new builder for temporal join configuration.

Trait Implementations

impl Clone for TemporalJoinConfig

fn clone(&self) -> TemporalJoinConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TemporalJoinConfig

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

Formats the value using the given formatter.