Struct mz_persist_client::batch::BatchParts

pub(crate) struct BatchParts<T> {
    cfg: BatchBuilderConfig,
    metrics: Arc<Metrics>,
    shard_metrics: Arc<ShardMetrics>,
    shard_id: ShardId,
    blob: Arc<dyn Blob>,
    isolated_runtime: Arc<IsolatedRuntime>,
    next_index: u64,
    writing_runs: WritingRuns<T>,
    batch_metrics: BatchWriteMetrics,
}

Fields

cfg: BatchBuilderConfig

metrics: Arc<Metrics>

shard_metrics: Arc<ShardMetrics>

shard_id: ShardId

blob: Arc<dyn Blob>

isolated_runtime: Arc<IsolatedRuntime>

next_index: u64

writing_runs: WritingRuns<T>

batch_metrics: BatchWriteMetrics

Implementations

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

pub(crate) fn new_compacting<K, V, D>( cfg: CompactConfig, desc: Description<T>, runs_per_compaction: usize, metrics: Arc<Metrics>, shard_metrics: Arc<ShardMetrics>, shard_id: ShardId, blob: Arc<dyn Blob>, isolated_runtime: Arc<IsolatedRuntime>, batch_metrics: &BatchWriteMetrics, schemas: Schemas<K, V>, ) -> Self

where K: Codec + Debug, V: Codec + Debug, T: Lattice + Send + Sync, D: Semigroup + Ord + Codec64 + Send + Sync,

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

pub(crate) fn expected_order(&self) -> RunOrder

pub(crate) async fn write<K: Codec, V: Codec, D: Codec64>( &mut self, write_schemas: &Schemas<K, V>, desc: Description<T>, updates: BlobTraceUpdates, 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>, run_order: RunOrder, ts_rewrite: Option<Antichain<T>>, diffs_sum: [u8; 8], write_schemas: Schemas<K, V>, ) -> BatchPart<T>

pub(crate) async fn finish(self) -> Vec<(RunOrder, Vec<RunPart<T>>)>

Trait Implementations

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

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

Formats the value using the given formatter.