Struct BatchBuilder

pub struct BatchBuilder<K, V, T, D>
where
    K: Codec,
    V: Codec,
    T: Timestamp + Lattice + Codec64,
{
    pub(crate) metrics: Arc<Metrics>,
    inline_desc: Description<T>,
    inclusive_upper: Antichain<Reverse<T>>,
    pub(crate) key_buf: Vec<u8>,
    pub(crate) val_buf: Vec<u8>,
    records_builder: Either<ColumnarRecordsBuilder, PartBuilder<K, K::Schema, V, V::Schema>>,
    pub(crate) builder: BatchBuilderInternal<K, V, T, D>,
}

A builder for Batches that allows adding updates piece by piece and then finishing it.

Fields

metrics: Arc<Metrics>

inline_desc: Description<T>

inclusive_upper: Antichain<Reverse<T>>

key_buf: Vec<u8>

val_buf: Vec<u8>

records_builder: Either<ColumnarRecordsBuilder, PartBuilder<K, K::Schema, V, V::Schema>>

builder: BatchBuilderInternal<K, V, T, D>

Implementations

impl<K, V, T, D> BatchBuilder<K, V, T, D>

where K: Debug + Codec, V: Debug + Codec, T: Timestamp + Lattice + Codec64, D: Semigroup + Codec64,

pub(crate) fn new( builder: BatchBuilderInternal<K, V, T, D>, inline_desc: Description<T>, metrics: Arc<Metrics>, ) -> Self

pub async fn finish( self, registered_upper: Antichain<T>, ) -> Result<Batch<K, V, T, D>, InvalidUsage<T>>

Finish writing this batch and return a handle to the written batch.

This fails if any of the updates in this batch are beyond the given upper.

pub async fn add( &mut self, key: &K, val: &V, ts: &T, diff: &D, ) -> Result<Added, InvalidUsage<T>>

Adds the given update to the batch.

The update timestamp must be greater or equal to lower that was given when creating this BatchBuilder.

Trait Implementations

impl<K, V, T, D: Debug> Debug for BatchBuilder<K, V, T, D>

where K: Codec + Debug, V: Codec + Debug, T: Timestamp + Lattice + Codec64 + Debug, K::Schema: Debug, V::Schema: Debug,

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

Formats the value using the given formatter.