Trait differential_dataflow::trace::Batch

source ·

pub trait Batch: BatchReaderwhere
    Self: Sized,{
    type Merger: Merger<Self>;

    // Required method
    fn empty(lower: Antichain<Self::Time>, upper: Antichain<Self::Time>) -> Self;

    // Provided method
    fn begin_merge(
        &self,
        other: &Self,
        compaction_frontier: AntichainRef<'_, Self::Time>,
    ) -> Self::Merger { ... }
}

Expand description

An immutable collection of updates.

Required Associated Types§

source

type Merger: Merger<Self>

A type used to progressively merge batches.

Required Methods§

source

fn empty(lower: Antichain<Self::Time>, upper: Antichain<Self::Time>) -> Self

Produce an empty batch over the indicated interval.

Provided Methods§

source

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

Initiates the merging of consecutive batches.

The result of this method can be exercised to eventually produce the same result that a call to self.merge(other) would produce, but it can be done in a measured fashion. This can help to avoid latency spikes where a large merge needs to happen.