Struct differential_dataflow::trace::implementations::ord::OrdKeyBatch

pub struct OrdKeyBatch<L: Layout>where
    <L::Target as Update>::Key: Sized,{
    pub layer: OrderedLayer<<<L as Layout>::Target as Update>::Key, OrderedLeaf<<<L as Layout>::Target as Update>::Time, <<L as Layout>::Target as Update>::Diff>, <L as Layout>::KeyOffset, <L as Layout>::KeyContainer>,
    pub desc: Description<<L::Target as Update>::Time>,
}

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

Fields

layer: OrderedLayer<<<L as Layout>::Target as Update>::Key, OrderedLeaf<<<L as Layout>::Target as Update>::Time, <<L as Layout>::Target as Update>::Diff>, <L as Layout>::KeyOffset, <L as Layout>::KeyContainer>

Where all the dataz is.

desc: Description<<L::Target as Update>::Time>

Description of the update times this layer represents.

Trait Implementations

impl<L> Abomonation for OrdKeyBatch<L>where <L::Target as Update>::Key: Sized, OrderedLayer<<<L as Layout>::Target as Update>::Key, OrderedLeaf<<<L as Layout>::Target as Update>::Time, <<L as Layout>::Target as Update>::Diff>, <L as Layout>::KeyOffset, <L as Layout>::KeyContainer>: Abomonation, L: Abomonation + Layout, Description<<L::Target as Update>::Time>: 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.

impl<L: Layout> Batch for OrdKeyBatch<L>where <L::Target as Update>::Key: Sized + Clone, L::Target: Update<Val = ()>,

type Merger = OrdKeyMerger<L>

A type used to progressively merge batches.

fn begin_merge( &self, other: &Self, compaction_frontier: AntichainRef<'_, <L::Target as Update>::Time> ) -> Self::Merger

Initiates the merging of consecutive batches.

impl<L: Layout> BatchReader for OrdKeyBatch<L>where <L::Target as Update>::Key: Sized + Clone,

type Key = <<L as Layout>::Target as Update>::Key

Key by which updates are indexed.

type Val = ()

Values associated with keys.

type Time = <<L as Layout>::Target as Update>::Time

Timestamps associated with updates

type Diff = <<L as Layout>::Target as Update>::Diff

Associated update.

type Cursor = OrdKeyCursor<L>

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<<L::Target as Update>::Time>

Describes the times of the updates in the batch.

fn is_empty(&self) -> bool

True if the batch is empty.

fn lower(&self) -> &Antichain<Self::Time>

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

fn upper(&self) -> &Antichain<Self::Time>

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

impl<L: Layout> Merger<OrdKeyBatch<L>> for OrdKeyMerger<L>where <L::Target as Update>::Key: Sized + Clone, OrdKeyBatch<L>: Batch<Time = <L::Target as Update>::Time>,

fn new( batch1: &OrdKeyBatch<L>, batch2: &OrdKeyBatch<L>, compaction_frontier: AntichainRef<'_, <L::Target as Update>::Time> ) -> Self

Creates a new merger to merge the supplied batches, optionally compacting up to the supplied frontier.

fn done(self) -> OrdKeyBatch<L>

Extracts merged results.

fn work( &mut self, source1: &OrdKeyBatch<L>, source2: &OrdKeyBatch<L>, fuel: &mut isize )

Perform some amount of work, decrementing fuel.