Struct differential_dataflow::trace::implementations::ord::OrdValBatch

pub struct OrdValBatch<K, V, T, R, O = usize> where
    K: Ord,
    V: Ord,
    T: Lattice,
    O: OrdOffset,
    <O as TryFrom<usize>>::Error: Debug,
    <O as TryInto<usize>>::Error: Debug,  {
    pub layer: OrderedLayer<K, OrderedLayer<V, OrderedLeaf<T, R>, O>, O>,
    pub desc: Description<T>,
}

An immutable collection of update tuples, from a contiguous interval of logical times.

Fields

layer: OrderedLayer<K, OrderedLayer<V, OrderedLeaf<T, R>, O>, O>

Where all the dataz is.

desc: Description<T>

Description of the update times this layer represents.

Trait Implementations

impl<K, V, T, R, O> BatchReader<K, V, T, R> for OrdValBatch<K, V, T, R, O> where
    K: Ord + Clone + 'static,
    V: Ord + Clone + 'static,
    T: Lattice + Ord + Clone + 'static,
    R: Semigroup,
    O: OrdOffset,
    <O as TryFrom<usize>>::Error: Debug,
    <O as TryInto<usize>>::Error: Debug, 

type Cursor = OrdValCursor<V, T, R, O>

The type used to enumerate the batch's contents.

fn cursor(&self) -> Self::Cursor

Acquires a cursor to the batch's contents.

fn len(&self) -> usize

The number of updates in the batch.

fn description(&self) -> &Description<T>

Describes the times of the updates in the batch.

fn is_empty(&self) -> bool

True if the batch is empty.

fn lower(&self) -> &[T]

All times in the batch are greater or equal to an element of lower.

fn upper(&self) -> &[T]

All times in the batch are not greater or equal to any element of upper.

impl<K, V, T, R, O> Batch<K, V, T, R> for OrdValBatch<K, V, T, R, O> where
    K: Ord + Clone + 'static,
    V: Ord + Clone + 'static,
    T: Lattice + Ord + Clone + Debug + 'static,
    R: Semigroup,
    O: OrdOffset,
    <O as TryFrom<usize>>::Error: Debug,
    <O as TryInto<usize>>::Error: Debug, 

type Batcher = MergeBatcher<K, V, T, R, Self>

A type used to assemble batches from disordered updates.

type Builder = OrdValBuilder<K, V, T, R, O>

A type used to assemble batches from ordered update sequences.

type Merger = OrdValMerger<K, V, T, R, O>

A type used to progressively merge batches.

fn begin_merge(&self, other: &Self) -> Self::Merger

Initiates the merging of consecutive batches.

fn empty(lower: &[T], upper: &[T], since: &[T]) -> Self

impl<K, V, T, R, O> Builder<K, V, T, R, OrdValBatch<K, V, T, R, O>> for OrdValBuilder<K, V, T, R, O> where
    K: Ord + Clone + 'static,
    V: Ord + Clone + 'static,
    T: Lattice + Ord + Clone + Debug + 'static,
    R: Semigroup,
    O: OrdOffset,
    <O as TryFrom<usize>>::Error: Debug,
    <O as TryInto<usize>>::Error: Debug, 

fn new() -> Self

Allocates an empty builder.

fn with_capacity(cap: usize) -> Self

Allocates an empty builder with some capacity.

fn push(&mut self, (key, val, time, diff): (K, V, T, R))

Adds an element to the batch.

fn done(
    self,
    lower: &[T],
    upper: &[T],
    since: &[T]
) -> OrdValBatch<K, V, T, R, O>

Completes building and returns the batch.

fn extend<I: Iterator<Item = (K, V, T, R)>>(&mut self, iter: I)

Adds an ordered sequence of elements to the batch.

impl<K, V, T, R, O> Merger<K, V, T, R, OrdValBatch<K, V, T, R, O>> for OrdValMerger<K, V, T, R, O> where
    K: Ord + Clone + 'static,
    V: Ord + Clone + 'static,
    T: Lattice + Ord + Clone + Debug + 'static,
    R: Semigroup,
    O: OrdOffset,
    <O as TryFrom<usize>>::Error: Debug,
    <O as TryInto<usize>>::Error: Debug, 

fn new(
    batch1: &OrdValBatch<K, V, T, R, O>,
    batch2: &OrdValBatch<K, V, T, R, O>
) -> Self

Creates a new merger to merge the supplied batches.

fn done(self) -> OrdValBatch<K, V, T, R, O>

Extracts merged results.

fn work(
    &mut self,
    source1: &OrdValBatch<K, V, T, R, O>,
    source2: &OrdValBatch<K, V, T, R, O>,
    frontier: &Option<Vec<T>>,
    fuel: &mut isize
)

Perform some amount of work, decrementing fuel.

impl<K: Debug, V: Debug, T: Debug, R: Debug, O: Debug> Debug for OrdValBatch<K, V, T, R, O> where
    K: Ord,
    V: Ord,
    T: Lattice,
    O: OrdOffset,
    <O as TryFrom<usize>>::Error: Debug,
    <O as TryInto<usize>>::Error: Debug, 

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<K, V, T, R, O> Abomonation for OrdValBatch<K, V, T, R, O> where
    K: Ord,
    V: Ord,
    T: Lattice,
    O: OrdOffset,
    <O as TryFrom<usize>>::Error: Debug,
    <O as TryInto<usize>>::Error: Debug,
    OrderedLayer<K, OrderedLayer<V, OrderedLeaf<T, R>, O>, O>: Abomonation,
    K: Abomonation,
    V: Abomonation,
    T: Abomonation,
    R: Abomonation,
    O: Abomonation,
    Description<T>: Abomonation, 

unsafe fn entomb<W: Write>(&self, _write: &mut W) -> Result<()>

Write any additional information about &self beyond its binary representation.

fn extent(&self) -> usize

Reports the number of further bytes required to entomb self.

unsafe fn exhume<'a, 'b>(
    &'a mut self,
    bytes: &'b mut [u8]
) -> Option<&'b mut [u8]>

Recover any information for &mut self not evident from its binary representation.