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

pub struct TraceWriter<Tr>
where
    Tr: Trace,
    Tr::Batch: Batch,
{ /* private fields */ }

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::Batch: Batch,

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)

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::Batch: Batch,

fn drop(&mut self)

Executes the destructor for this type.