Struct differential_dataflow::operators::arrange::writer::TraceWriter

pub struct TraceWriter<Tr> where
    Tr: Trace,
    Tr::Time: Lattice + Timestamp + Ord + Clone + Debug + 'static,
    Tr::Batch: Batch<Tr::Key, Tr::Val, Tr::Time, Tr::R>,  { /* fields omitted */ }

Write endpoint for a sequence of batches.

A TraceWriter accepts a sequence of batches and distributes them to both a shared trace and to a sequence of private queues.

Implementations

impl<Tr> TraceWriter<Tr> where
    Tr: Trace,
    Tr::Time: Lattice + Timestamp + Ord + Clone + Debug + 'static,
    Tr::Batch: Batch<Tr::Key, Tr::Val, Tr::Time, Tr::R>, 

pub fn new(
    upper: Vec<Tr::Time>,
    trace: Weak<RefCell<TraceBox<Tr>>>,
    queues: Rc<RefCell<Vec<Weak<(Activator, RefCell<VecDeque<TraceReplayInstruction<Tr>>>)>>>>
) -> Self

Creates a new TraceWriter.

pub fn exert(&mut self, fuel: &mut isize)

Exerts merge effort, even without additional updates.

pub fn insert(&mut self, batch: Tr::Batch, hint: Option<Tr::Time>)

Advances the trace by batch.

The hint argument is either None in the case of an empty batch, or is Some(time) for a time less or equal to all updates in the batch and which is suitable for use as a capability.

pub fn seal(&mut self, upper: Antichain<Tr::Time>)

Inserts an empty batch up to upper.

Trait Implementations

impl<Tr> Drop for TraceWriter<Tr> where
    Tr: Trace,
    Tr::Time: Lattice + Timestamp + Ord + Clone + Debug + 'static,
    Tr::Batch: Batch<Tr::Key, Tr::Val, Tr::Time, Tr::R>, 

fn drop(&mut self)

Executes the destructor for this type.