Struct StreamJoinConfigBuilder 

pub struct StreamJoinConfigBuilder { /* private fields */ }

Builder for StreamJoinConfig.

Implementations

impl StreamJoinConfigBuilder

pub fn left_key_column(self, column: impl Into<String>) -> Self

Sets the left stream key column name.

pub fn right_key_column(self, column: impl Into<String>) -> Self

Sets the right stream key column name.

pub fn time_bound(self, duration: Duration) -> Self

Sets the time bound for matching events.

pub fn time_bound_ms(self, ms: i64) -> Self

Sets the time bound in milliseconds.

pub fn join_type(self, join_type: JoinType) -> Self

Sets the join type.

pub fn operator_id(self, id: impl Into<String>) -> Self

Sets the operator ID for checkpointing.

pub fn row_encoding(self, encoding: JoinRowEncoding) -> Self

Sets the row encoding strategy (F057).

pub fn asymmetric_compaction(self, enabled: bool) -> Self

Enables or disables asymmetric compaction (F057).

pub fn idle_threshold(self, duration: Duration) -> Self

Sets the idle threshold for asymmetric compaction (F057).

pub fn per_key_tracking(self, enabled: bool) -> Self

Enables or disables per-key tracking (F057).

pub fn key_idle_threshold(self, duration: Duration) -> Self

Sets the key idle threshold for cleanup (F057).

pub fn build_side_pruning(self, enabled: bool) -> Self

Enables or disables build-side pruning (F057).

pub fn build_side(self, side: JoinSide) -> Self

Sets which side to use as the build side (F057).

pub fn build(self) -> StreamJoinConfig

Builds the configuration.

Trait Implementations

impl Debug for StreamJoinConfigBuilder

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

Formats the value using the given formatter.

impl Default for StreamJoinConfigBuilder

fn default() -> StreamJoinConfigBuilder

Returns the “default value” for a type.