Struct mz_persist_client::batch::BatchParts

pub(crate) struct BatchParts<T> {
    cfg: BatchBuilderConfig,
    metrics: Arc<Metrics>,
    shard_metrics: Arc<ShardMetrics>,
    shard_id: ShardId,
    lower: Antichain<T>,
    blob: Arc<dyn Blob>,
    isolated_runtime: Arc<IsolatedRuntime>,
    writing_parts: VecDeque<JoinHandle<BatchPart<T>>>,
    finished_parts: Vec<BatchPart<T>>,
    batch_metrics: BatchWriteMetrics,
}

Fields

cfg: BatchBuilderConfig

metrics: Arc<Metrics>

shard_metrics: Arc<ShardMetrics>

shard_id: ShardId

lower: Antichain<T>

blob: Arc<dyn Blob>

isolated_runtime: Arc<IsolatedRuntime>

writing_parts: VecDeque<JoinHandle<BatchPart<T>>>

finished_parts: Vec<BatchPart<T>>

batch_metrics: BatchWriteMetrics

Implementations

impl<T: Timestamp + Codec64> BatchParts<T>

pub(crate) fn new( cfg: BatchBuilderConfig, metrics: Arc<Metrics>, shard_metrics: Arc<ShardMetrics>, shard_id: ShardId, lower: Antichain<T>, blob: Arc<dyn Blob>, isolated_runtime: Arc<IsolatedRuntime>, batch_metrics: &BatchWriteMetrics, ) -> Self

pub(crate) async fn write<K: Codec, V: Codec, D: Codec64>( &mut self, schemas: &Schemas<K, V>, key_lower: Vec<u8>, updates: ColumnarRecords, upper: Antichain<T>, since: Antichain<T>, diffs_sum: D, )

async fn write_hollow_part<K: Codec, V: Codec>( cfg: BatchBuilderConfig, part_write_columnar_data: bool, blob: Arc<dyn Blob>, metrics: Arc<Metrics>, shard_metrics: Arc<ShardMetrics>, batch_metrics: BatchWriteMetrics, isolated_runtime: Arc<IsolatedRuntime>, updates: BlobTraceBatchPart<T>, key_lower: Vec<u8>, ts_rewrite: Option<Antichain<T>>, diffs_sum: [u8; 8], schemas: Schemas<K, V>, ) -> BatchPart<T>

pub(crate) async fn finish(self) -> Vec<BatchPart<T>>

Trait Implementations

impl<T: Debug> Debug for BatchParts<T>

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

Formats the value using the given formatter.