WindowAssigner

rlink::core::window

Trait WindowAssigner 

Source 
pub trait WindowAssigner
where
    Self: NamedFunction + CheckpointFunction + Debug,
{
    // Required method
    fn assign_windows(
        &self,
        timestamp: u64,
        context: WindowAssignerContext,
    ) -> Vec<Window>;
}
Expand description

A WindowAssigner assigns zero or more Windows to an element.

Required Methods§

Source

fn assign_windows( &self, timestamp: u64, context: WindowAssignerContext, ) -> Vec<Window>

Returns a collection of windows that should be assigned to the element.

Implementors§