Struct differential_dataflow::operators::arrange::TraceWriter

pub struct TraceWriter<K, V, T, R, Tr> where
    T: Lattice + Ord + Clone + 'static,
    Tr: Trace<K, V, T, R>,
    Tr::Batch: Batch<K, V, T, R>,  { /* fields omitted */ }

A trace writer capability.

Methods

impl<K, V, T, R, Tr> TraceWriter<K, V, T, R, Tr> where
    T: Lattice + Ord + Clone + 'static,
    Tr: Trace<K, V, T, R>,
    Tr::Batch: Batch<K, V, T, R>, 

pub fn seal(&mut self, frontier: &[T], data: Option<(T, Tr::Batch)>)

Advances the trace to frontier, providing batch data if it exists.

Trait Implementations

impl<K, V, T, R, Tr> Drop for TraceWriter<K, V, T, R, Tr> where
    T: Lattice + Ord + Clone + 'static,
    Tr: Trace<K, V, T, R>,
    Tr::Batch: Batch<K, V, T, R>, 

fn drop(&mut self)

Executes the destructor for this type.