Struct CoGroupOperator 

pub struct CoGroupOperator { /* private fields */ }

CoGroup operator for two streams.

Implementations

impl CoGroupOperator

pub fn new() -> Self

Create a new cogroup operator.

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

Add a left element.

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

Add a right element.

pub async fn get_results( &self, key: &[u8], ) -> (Vec<StreamElement>, Vec<StreamElement>)

Get cogroup results for a key.

pub async fn clear(&self)

Clear buffers.

Trait Implementations

impl Default for CoGroupOperator

fn default() -> Self

Returns the “default value” for a type.