Struct TransactionWindow 

pub struct TransactionWindow<T, F: Fn(&T) -> TransactionOp> { /* private fields */ }

Window that closes according to user supplied logic

• Windows are implicitly created when the first element for the partition is received.
• Only one window per partition can be active at the same time.
• The logic function determines when (and if) the window should be committed producing an output.
• The logic function is called on each element before it is passed to the accumulator.
• Returning TransactionOp::Continue will keep the window open and continue processing.
• Returing TransactionOp::Commit will close the current window and generate an output. (The element triggering the commit will be included in the window)
• Returning TransactionOp::Discard will close the window dropping the accumulator without producing an output
• Returning TransactionOp::CommitAfter will register the window to be commited after a watermark with event time greater than the specified time has been received. The commit time can be overwritten by another message or cancelled by returning TransactionOp::Discard.

Implementations

impl<T, F: Fn(&T) -> TransactionOp> TransactionWindow<T, F>

pub fn new(logic: F) -> Self

Trait Implementations

impl<T: Clone, F: Clone + Fn(&T) -> TransactionOp> Clone for TransactionWindow<T, F>

fn clone(&self) -> TransactionWindow<T, F>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Data, F: Fn(&T) -> TransactionOp + Data> WindowDescription<T> for TransactionWindow<T, F>

type Manager<A: WindowAccumulator<In = T>> = TransactionWindowManager<A, F>

WindowManager corresponding to the WindowDescription

fn build<A: WindowAccumulator<In = T>>( &self, accumulator: A, ) -> Self::Manager<A>

Build a window manager that dispatches elements of each window to a clone of the accumulator passed as parameter