Struct SegmentMerger 

pub struct SegmentMerger { /* private fields */ }

Segment merger - merges multiple segments into one

Implementations

impl SegmentMerger

pub fn new(schema: Arc<Schema>) -> Self

pub fn with_bmp_reorder(self, reorder: bool) -> Self

Enable BP reordering of BMP fields during the merge (see reorder_bmp).

pub fn with_background_pool(self, pool: Option<Arc<ThreadPool>>) -> Self

Run merge-time BP on this bounded pool instead of the global one.

pub fn with_granularity(self, granularity: BpGranularity) -> Self

Set merge-time BP granularity (see granularity).

pub async fn merge<D: Directory + DirectoryWriter>( &self, dir: &D, segments: &[SegmentReader], new_segment_id: SegmentId, trained: Option<&TrainedVectorStructures>, ) -> Result<(SegmentMeta, MergeStats)>

Merge segments into one, streaming postings/positions/store directly to files.

If trained is provided, dense vectors use O(1) cluster merge when possible (homogeneous IVF/ScaNN), otherwise rebuilds ANN from trained structures. Without trained structures, only flat vectors are merged.

Uses streaming writers so postings, positions, and store data flow directly to files instead of buffering everything in memory. Only the term dictionary (compact key+TermInfo entries) is buffered.