Trait declarative_dataflow::timestamp::Coarsen

pub trait Coarsen {
    fn coarsen(&self, window_size: &Self) -> Self;
}

Extension trait for timestamp types that can be rounded up to interval bounds, thus coarsening the granularity of timestamps and delaying results.

Required methods

fn coarsen(&self, window_size: &Self) -> Self

Returns a new timestamp delayed up to the next multiple of the specified window size.

Loading content...

Implementations on Foreign Types

impl Coarsen for u64

fn coarsen(&self, window_size: &Self) -> Self

impl Coarsen for Duration

fn coarsen(&self, window_size: &Self) -> Self

Loading content...

Implementors

impl Coarsen for Pair<Duration, u64>

fn coarsen(&self, window_size: &Self) -> Self

Loading content...