Struct mz_persist_client::batch::BatchBuilderInternal

pub(crate) struct BatchBuilderInternal<K, V, T, D>
where
    K: Codec,
    V: Codec,
    T: Timestamp + Lattice + Codec64,
{
    shard_id: ShardId,
    version: Version,
    blob: Arc<dyn Blob>,
    metrics: Arc<Metrics>,
    write_schemas: Schemas<K, V>,
    num_updates: usize,
    parts: BatchParts<T>,
    _phantom: PhantomData<fn(_: K, _: V, _: T, _: D)>,
}

Fields

shard_id: ShardId

version: Version

blob: Arc<dyn Blob>

metrics: Arc<Metrics>

write_schemas: Schemas<K, V>

num_updates: usize

parts: BatchParts<T>

_phantom: PhantomData<fn(_: K, _: V, _: T, _: D)>

Implementations

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

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

pub(crate) fn new( _cfg: BatchBuilderConfig, parts: BatchParts<T>, metrics: Arc<Metrics>, write_schemas: Schemas<K, V>, blob: Arc<dyn Blob>, shard_id: ShardId, version: Version, ) -> Self

pub async fn finish( self, registered_desc: Description<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 flush_part( &mut self, part_desc: Description<T>, columnar: BlobTraceUpdates, )

Flushes the current part to Blob storage, first consolidating and then columnar encoding the updates. It is the caller’s responsibility to chunk current_part to be no greater than BatchBuilderConfig::blob_target_size, and must absolutely be less than mz_persist::indexed::columnar::KEY_VAL_DATA_MAX_LEN

Trait Implementations

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

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

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

Formats the value using the given formatter.