Struct IntervalJoin 

pub struct IntervalJoin { /* private fields */ }

Interval join operator.

Implementations

impl IntervalJoin

pub fn new(lower_bound_seconds: i64, upper_bound_seconds: i64) -> Self

Create a new interval join.

pub async fn process_left( &self, element: StreamElement, ) -> Result<Vec<StreamElement>>

Process a left element.

pub async fn process_right( &self, element: StreamElement, ) -> Result<Vec<StreamElement>>

Process a right element.

pub async fn clear(&self)

Clear buffers.