Method complete_build

nodedb-vector/src/collection/lifecycle.rs:199–244

Accept a completed HNSW build from the background thread. After promoting the segment to sealed, rebuilds the collection-level codec-dispatch index when `self.quantization` is `RaBitQ` or `Bbq`. The rebuild trains over all vectors so the codec index always covers every sealed segment.

(&mut self, segment_id: u32, index: HnswIndex)

    /// The rebuild trains over all vectors so the codec index always covers
    /// every sealed segment.
    pub fn complete_build(&mut self, segment_id: u32, index: HnswIndex) {
        if let Some(pos) = self
            .building
            .iter()
            .position(|b| b.segment_id == segment_id)
        {
            let building = self.building.remove(pos);
            let use_codec_dispatch = matches!(
                self.quantization,
                VectorQuantization::RaBitQ | VectorQuantization::Bbq
            );
            let use_pq = !use_codec_dispatch && self.index_config.index_type == IndexType::HnswPq;
            let (sq8, pq) = if use_codec_dispatch {
                (None, None)
            } else if use_pq {
                (
                    None,
                    Self::build_pq_for_index(&index, self.index_config.pq_m),
                )
            } else {
                (Self::build_sq8_for_index(&index), None)
            };
            let (tier, mmap_vectors) =
                self.resolve_tier_for_build(segment_id, building.base_id, &index);

            self.sealed.push(SealedSegment {
                index,
                base_id: building.base_id,
                sq8,
                pq,
                tier,
                mmap_vectors,
            });

            if use_codec_dispatch {
                let tag = match self.quantization {
                    VectorQuantization::RaBitQ => "rabitq",
                    VectorQuantization::Bbq => "bbq",
                    _ => unreachable!(
                        "invariant: use_codec_dispatch is only true for RaBitQ and Bbq quantization variants"
                    ),
                };
                self.build_codec_dispatch(tag);
            }
        }
    }

    /// Access sealed segments (read-only).
    pub fn sealed_segments(&self) -> &[SealedSegment] {