Struct CursorTactic 

pub struct CursorTactic<B1, B2, Bu, L, P>
where
    B1: Navigable,
    B2: Navigable,
    for<'a> B2::Cursor: Cursor<Key<'a> = <B1::Cursor as Cursor>::Key<'a>, ValOwn: Data, Time = <<B1 as Navigable>::Cursor as Cursor>::Time>,
{ /* private fields */ }

The conventional cursor-based ReduceTactic.

It builds a CursorList over the input, output, and new-batch updates and replays them together per key, applying logic and shaping output with push. It holds the outstanding synthetic interesting (key, time) moments across activations, and reasons only about times: capabilities are the driver’s concern. The conventional cursor-based ReduceTactic.

Implementations

impl<B1, B2, Bu, L, P> CursorTactic<B1, B2, Bu, L, P>

where B1: Navigable, B2: Navigable, for<'a> B2::Cursor: Cursor<Key<'a> = <B1::Cursor as Cursor>::Key<'a>, ValOwn: Data, Time = <<B1 as Navigable>::Cursor as Cursor>::Time>,

pub fn new(logic: L, push: P) -> Self

Construct a tactic that applies logic to each key and shapes output with push.

Trait Implementations

impl<B1, B2, Bu, L, P> ReduceTactic<<<B1 as Navigable>::Cursor as Cursor>::Time, B1, B2> for CursorTactic<B1, B2, Bu, L, P>

where B1: Navigable, B2: Navigable, for<'a> B2::Cursor: Cursor<Key<'a> = <B1::Cursor as Cursor>::Key<'a>, ValOwn: Data, Time = <<B1 as Navigable>::Cursor as Cursor>::Time>, Bu: Builder<Time = <<B1 as Navigable>::Cursor as Cursor>::Time, Output: Into<B2>, Input: Default>, L: FnMut(<B1::Cursor as Cursor>::Key<'_>, &[(<B1::Cursor as Cursor>::Val<'_>, <B1::Cursor as Cursor>::Diff)], &mut Vec<(<B2::Cursor as Cursor>::ValOwn, <B2::Cursor as Cursor>::Diff)>, &mut Vec<(<B2::Cursor as Cursor>::ValOwn, <B2::Cursor as Cursor>::Diff)>), P: FnMut(&mut Bu::Input, <B1::Cursor as Cursor>::Key<'_>, &mut Vec<(<B2::Cursor as Cursor>::ValOwn, <<B1 as Navigable>::Cursor as Cursor>::Time, <B2::Cursor as Cursor>::Diff)>),

fn retire( &mut self, source_batches: Vec<B1>, output_batches: Vec<B2>, input_batches: Vec<B1>, lower: &Antichain<<<B1 as Navigable>::Cursor as Cursor>::Time>, upper: &Antichain<<<B1 as Navigable>::Cursor as Cursor>::Time>, held: &Antichain<<<B1 as Navigable>::Cursor as Cursor>::Time>, ) -> (Option<Span<<<B1 as Navigable>::Cursor as Cursor>::Time, B2>>, Antichain<<<B1 as Navigable>::Cursor as Cursor>::Time>)

Retire the interval [lower, upper), producing the output batch it informs.