Struct TemporalJoinOperator 

pub struct TemporalJoinOperator { /* private fields */ }

Temporal join operator.

Performs point-in-time lookups against a versioned table. Supports both append-only tables (optimized, no stream-side state) and non-append-only tables (with retraction support).

Implementations

impl TemporalJoinOperator

pub fn new(config: TemporalJoinConfig) -> Self

Creates a new temporal join operator.

pub fn with_id(config: TemporalJoinConfig, operator_id: String) -> Self

Creates a new temporal join operator with explicit ID.

pub fn config(&self) -> &TemporalJoinConfig

Returns the configuration.

pub fn metrics(&self) -> &TemporalJoinMetrics

Returns the metrics.

pub fn reset_metrics(&mut self)

Resets the metrics.

pub fn watermark(&self) -> i64

Returns the current watermark.

pub fn table_state_size(&self) -> usize

Returns the total number of table rows in state.

pub fn stream_state_size(&self) -> usize

Returns the total number of tracked stream events (non-append-only only).

pub fn process_stream( &mut self, event: &Event, ctx: &mut OperatorContext<'_>, ) -> OutputVec

Processes a stream event (probe side).

pub fn process_table_insert( &mut self, event: &Event, _ctx: &mut OperatorContext<'_>, ) -> OutputVec

Processes a table insert (append-only or non-append-only).

pub fn process_table_change( &mut self, change: &TableChange, _ctx: &mut OperatorContext<'_>, ) -> OutputVec

Processes a table change (non-append-only tables). Returns retractions and new join results for affected stream events.

pub fn on_watermark( &mut self, watermark: i64, _ctx: &mut OperatorContext<'_>, ) -> OutputVec

Handles watermark updates and triggers cleanup.

Trait Implementations

impl Operator for TemporalJoinOperator

fn process(&mut self, event: &Event, ctx: &mut OperatorContext<'_>) -> OutputVec

Process an incoming event

fn on_timer( &mut self, timer: Timer, _ctx: &mut OperatorContext<'_>, ) -> OutputVec

Handle timer expiration

fn checkpoint(&self) -> OperatorState

Checkpoint the operator’s state

fn restore(&mut self, state: OperatorState) -> Result<(), OperatorError>

Restore from a checkpoint