Skip to main content

WindowAssigner

oxigdal_streaming::windowing

Trait WindowAssigner 

Source 
pub trait WindowAssigner: Send + Sync {
    // Required methods
    fn assign_windows(&self, element: &StreamElement) -> Result<Vec<Window>>;
    fn assigner_type(&self) -> &str;
}
Expand description

Assigns elements to windows.

Required Methods§

Source

fn assign_windows(&self, element: &StreamElement) -> Result<Vec<Window>>

Assign an element to one or more windows.

Source

fn assigner_type(&self) -> &str

Get the window assigner type name.

Implementors§