Struct CursorTactic 

pub struct CursorTactic<B0, B1, L, CB>
where
    B0: Navigable,
    B1: Navigable,
    B1::Cursor: for<'a> Cursor<Key<'a> = <B0::Cursor as Cursor>::Key<'a>, Time = <B0::Cursor as Cursor>::Time>,
{ /* private fields */ }

The conventional cursor-based JoinTactic.

It builds a CursorList over each input batch list and plays the merge-join out at whatever rate the driver’s fuel allows. Each prepared unit joins a B0-side cursor against a B1-side cursor, emitting (val0, val1) to logic and yielding the output containers logic fills. logic is shared across all outstanding units (an Rc<RefCell<_>>), preserving the single mutable-state semantics of one closure threaded through every match — each unit is a self-contained 'static iterator, so it cannot borrow the tactic.

It is parameterized by the builder CB into which logic pushes output; the JoinTactic it implements is over the container CB yields (CB::Container).

Implementations

impl<B0, B1, L, CB> CursorTactic<B0, B1, L, CB>

where B0: Navigable, B1: Navigable, B1::Cursor: for<'a> Cursor<Key<'a> = <B0::Cursor as Cursor>::Key<'a>, Time = <B0::Cursor as Cursor>::Time>,

pub fn new(logic: L) -> Self

Construct a tactic that applies logic to each matched (key, val0, val1).

Trait Implementations

impl<B0, B1, L, CB> JoinTactic<<<B0 as Navigable>::Cursor as Cursor>::Time, B0, B1, <CB as ContainerBuilder>::Container> for CursorTactic<B0, B1, L, CB>

where B0: Navigable + 'static, B1: Navigable + 'static, B1::Cursor: for<'a> Cursor<Key<'a> = <B0::Cursor as Cursor>::Key<'a>, Time = <B0::Cursor as Cursor>::Time>, CB: ContainerBuilder<Container: Default> + 'static, L: for<'a> FnMut(<B0::Cursor as Cursor>::Key<'a>, <B0::Cursor as Cursor>::Val<'a>, <B1::Cursor as Cursor>::Val<'a>, <B0::Cursor as Cursor>::Time, &<B0::Cursor as Cursor>::Diff, &<B1::Cursor as Cursor>::Diff, &mut CB) + 'static,

fn prep( &mut self, input0: Vec<B0>, input1: Vec<B1>, fresh: Fresh, meet: <B0::Cursor as Cursor>::Time, ) -> Box<dyn Iterator<Item = CB::Container>>

Prepare the join of two lists of batches into an iterator of output containers.