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 fn with_bp_budget(self, budget: BpBudget) -> Self

Bound merge-time BP wall clock (see bp_budget).

pub fn with_bp_memory_budget(self, bytes: usize) -> Self

Memory budget for the BP forward index (see bp_memory_budget).

pub fn with_reorder_permits(self, permits: Arc<Semaphore>) -> Self

Share the application-wide whole-segment reorder gate.

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.