Struct BatchWriter 

pub struct BatchWriter { /* private fields */ }

Convenience writer using the canonical configured mutation executor.

ParallelConfig changes scheduling only. Chunk boundaries, serialized nodes, and roots are invariant across worker widths.

use prolly::{BatchWriter, ParallelConfig};

let writer = BatchWriter::with_config(ParallelConfig::new(4, 256));
assert_eq!(writer.config().max_threads, 4);

Implementations

impl BatchWriter

pub fn new() -> Self

Create a new batch writer with default configuration.

Returns

A new BatchWriter with default settings.

Example

use prolly::BatchWriter;

let writer = BatchWriter::new();

pub fn with_config(config: ParallelConfig) -> Self

Create a writer with explicit canonical scheduling preferences.

use prolly::{BatchWriter, ParallelConfig};

let writer = BatchWriter::with_config(ParallelConfig::new(8, 512));
assert_eq!(writer.config().parallelism_threshold, 512);

pub fn config(&self) -> &ParallelConfig

Return the writer’s scheduling policy.

use prolly::BatchWriter;

let writer = BatchWriter::new();
assert_eq!(writer.config().parallelism_threshold, 100);

pub fn apply_batch<S: Store>( &self, prolly: &Prolly<S>, tree: &Tree, mutations: Vec<Mutation>, ) -> Result<Tree, Error>

Apply mutations through the canonical writer using this scheduling policy.

Arguments

• prolly - Reference to the Prolly tree manager
• tree - The tree to modify
• mutations - Vector of mutations to apply

Returns

• Ok(Tree) - New tree with all mutations applied
• Err(Error) - On storage or processing errors

Example

use prolly::{BatchWriter, Prolly, MemStore, Config, Mutation};

let store = MemStore::new();
let prolly = Prolly::new(store, Config::default());
let tree = prolly.create();

let writer = BatchWriter::new();
let mutations = vec![
    Mutation::Upsert { key: b"key".to_vec(), val: b"value".to_vec() },
];

let new_tree = writer.apply_batch(&prolly, &tree, mutations).unwrap();

pub fn apply_batch_with_stats<S: Store>( &self, prolly: &Prolly<S>, tree: &Tree, mutations: Vec<Mutation>, ) -> Result<BatchApplyResult, Error>

Apply batch mutations and return store-neutral execution stats.

This is useful for tuning workload shape across storage backends. The returned stats report tree-level work such as affected leaves and unique prolly nodes/bytes written, independent of backend compaction or object layout.

Trait Implementations

impl Default for BatchWriter

fn default() -> Self

Returns the “default value” for a type.