Method finalize_sampling

src/indexes/usv.rs:193–246

(
        &self,
        lmdb: &MetaDb,
        config: &Config,
        _embeddings: &[Self::IndexingInput],
    )

    }

    fn finalize_sampling(
        &self,
        lmdb: &MetaDb,
        config: &Config,
        _embeddings: &[Self::IndexingInput],
    ) -> Result<(), WaCustomError> {
        let values_count = self.sampling_data.values_collected.load(Ordering::Relaxed) as f32;

        let above_1_percent =
            (self.sampling_data.above_1.load(Ordering::Relaxed) as f32 / values_count) * 100.0;
        let above_2_percent =
            (self.sampling_data.above_2.load(Ordering::Relaxed) as f32 / values_count) * 100.0;
        let above_3_percent =
            (self.sampling_data.above_3.load(Ordering::Relaxed) as f32 / values_count) * 100.0;
        let above_4_percent =
            (self.sampling_data.above_4.load(Ordering::Relaxed) as f32 / values_count) * 100.0;
        let above_5_percent =
            (self.sampling_data.above_5.load(Ordering::Relaxed) as f32 / values_count) * 100.0;
        let above_6_percent =
            (self.sampling_data.above_6.load(Ordering::Relaxed) as f32 / values_count) * 100.0;
        let above_7_percent =
            (self.sampling_data.above_7.load(Ordering::Relaxed) as f32 / values_count) * 100.0;
        let above_8_percent =
            (self.sampling_data.above_8.load(Ordering::Relaxed) as f32 / values_count) * 100.0;
        let above_9_percent =
            (self.sampling_data.above_9.load(Ordering::Relaxed) as f32 / values_count) * 100.0;

        let values_upper_bound = if above_1_percent <= config.indexing.clamp_margin_percent {
            1.0
        } else if above_2_percent <= config.indexing.clamp_margin_percent {
            2.0
        } else if above_3_percent <= config.indexing.clamp_margin_percent {
            3.0
        } else if above_4_percent <= config.indexing.clamp_margin_percent {
            4.0
        } else if above_5_percent <= config.indexing.clamp_margin_percent {
            5.0
        } else if above_6_percent <= config.indexing.clamp_margin_percent {
            6.0
        } else if above_7_percent <= config.indexing.clamp_margin_percent {
            7.0
        } else if above_8_percent <= config.indexing.clamp_margin_percent {
            8.0
        } else if above_9_percent <= config.indexing.clamp_margin_percent {
            9.0
        } else {
            10.0
        };

        *self.values_upper_bound.write().unwrap() = values_upper_bound;
        self.is_configured.store(true, Ordering::Release);
        store_usv_values_upper_bound(lmdb, values_upper_bound)?;
        Ok(())
    }

    fn embeddings_collected(&self) -> &RwLock<Vec<Self::IndexingInput>> {
        &self.vectors