Trait rlink::api::window::WindowAssigner[][src]

pub trait WindowAssigner where
    Self: NamedFunction + CheckpointFunction + Debug
{ fn assign_windows(
        &self,
        timestamp: u64,
        context: WindowAssignerContext
    ) -> Vec<Window>

Notable traits for Vec<u8, A>

impl<A> Write for Vec<u8, A> where
    A: Allocator
; }

Required methods

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

Notable traits for Vec<u8, A>

impl<A> Write for Vec<u8, A> where
    A: Allocator
[src]

Loading content...

Implementors

impl WindowAssigner for SlidingEventTimeWindows[src]

Loading content...