Struct Window 

pub struct Window<T> { /* private fields */ }

Available on crate feature std only.

A closed window of items with a start and end instant.

start <= end always holds. For tumbling and sliding windows end - start == size (modulo end-of-stream flushes). For session windows end is the instant of the last item that arrived inside the session.

Implementations

impl<T> Window<T>

pub fn new(items: Vec<T>, start: Instant, end: Instant) -> Self

Construct a window directly from parts. Primarily for tests and custom Stage implementations.

pub fn items(&self) -> &[T]

Items in this window, in arrival order.

pub fn len(&self) -> usize

Number of items in the window.

pub fn is_empty(&self) -> bool

True if the window holds no items.

pub fn start(&self) -> Instant

Window start instant.

pub fn end(&self) -> Instant

Window end instant. For tumbling/sliding, this is start + size. For session, this is the timestamp of the last item.

pub fn into_inner(self) -> Vec<T>

Unwrap the inner item vec.

Trait Implementations

impl<T: Clone> Clone for Window<T>

fn clone(&self) -> Window<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for Window<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a, T> IntoIterator for &'a Window<T>

type Item = &'a T

The type of the elements being iterated over.

type IntoIter = Iter<'a, T>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<T> IntoIterator for Window<T>

type Item = T

The type of the elements being iterated over.

type IntoIter = IntoIter<T>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.