Struct TumblingTimeWindow 

pub struct TumblingTimeWindow<T, M> { /* private fields */ }

Reactive time-tumbling window (push(now, v) + tick(now)).

Implementations

impl<T: Clone + PartialEq + 'static, M: MergePolicy<T>> TumblingTimeWindow<T, M>

pub fn new(ctx: &Context, period: u64) -> Self

pub fn push(&self, _ctx: &Context, now: u64, v: T)

pub fn tick(&self, ctx: &Context, now: u64) -> Option<T>

pub fn output(&self, ctx: &Context) -> Option<T>

pub fn output_cell(&self) -> Source<Option<T>>