Struct StreamJoinConfig 

pub struct StreamJoinConfig {
    pub left_key: String,
    pub right_key: String,
    pub time_bound: Duration,
    pub join_type: StreamJoinType,
}

Configuration for stream-stream join operator

Fields

left_key: String

Left side key column

right_key: String

Right side key column

time_bound: Duration

Time bound for joining (max time difference between events)

join_type: StreamJoinType

Join type

Implementations

impl StreamJoinConfig

pub fn new( left_key: String, right_key: String, time_bound: Duration, join_type: StreamJoinType, ) -> Self

Create a new stream-stream join configuration.

pub fn inner(left_key: String, right_key: String, time_bound: Duration) -> Self

Create an inner join configuration.

pub fn left(left_key: String, right_key: String, time_bound: Duration) -> Self

Create a left join configuration.

Trait Implementations

impl Clone for StreamJoinConfig

fn clone(&self) -> StreamJoinConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamJoinConfig

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

Formats the value using the given formatter.

impl Display for StreamJoinConfig

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

Formats the value using the given formatter.