Struct EagerParallelStoreWriter 

pub struct EagerParallelStoreWriter<'a> { /* private fields */ }

Parallel document store writer - compresses blocks immediately when queued

A fixed number of workers compress blocks while the caller continues accepting documents. Submitted blocks and out-of-order results are bounded, and completed blocks are written continuously in sequence order.

Implementations

impl<'a> EagerParallelStoreWriter<'a>

pub fn new(writer: &'a mut dyn Write, num_threads: usize) -> Self

Create a new eager parallel store writer

pub fn with_compression_level( writer: &'a mut dyn Write, num_threads: usize, compression_level: CompressionLevel, ) -> Self

Create with specific compression level

pub fn with_dict( writer: &'a mut dyn Write, dict: CompressionDict, num_threads: usize, ) -> Self

Create with dictionary

pub fn with_dict_and_level( writer: &'a mut dyn Write, dict: CompressionDict, num_threads: usize, compression_level: CompressionLevel, ) -> Self

Create with dictionary and specific compression level

pub fn store(&mut self, doc: &Document, schema: &Schema) -> Result<DocId>

pub fn store_raw(&mut self, doc_bytes: &[u8]) -> Result<DocId>

Store pre-serialized document bytes directly (avoids deserialize+reserialize roundtrip).

pub fn finish(self) -> Result<u32>