Struct SelectivityFeedbackManager 

pub struct SelectivityFeedbackManager { /* private fields */ }

Selective Feedback Manager

Managing selective feedback based on multiple conditions.

Examples

use linkrs_query::optimizer::stats::feedback::selectivity::SelectivityFeedbackManager;

let manager = SelectivityFeedbackManager::new();
manager.register_condition("age > 25".to_string(), 0.3);

let corrected = manager.get_corrected_selectivity("age > 25");
assert!(corrected.is_some());

Implementations

impl SelectivityFeedbackManager

pub fn new() -> Self

Create a new feedback manager.

pub fn with_params(alpha: f64, min_correction: f64, max_correction: f64) -> Self

Created using custom parameters

pub fn register_condition(&self, key: String, estimated_selectivity: f64)

Selective estimation of registration requirements

Registers the condition only when the key is not present yet, so repeated estimation of the same predicate does not reset previously learned corrections.

pub fn refresh_estimated(&self, key: &str, estimated_selectivity: f64) -> bool

Update the baseline estimate of a registered condition while preserving its learned correction factor, so baselines track fresh statistics instead of freezing at first sight. Returns false when the key is unknown.

pub fn get_corrected_selectivity(&self, key: &str) -> Option<f64>

Getting corrected selectivity

pub fn snapshot(&self) -> SelectivitySnapshot

Capture an immutable snapshot of the current learned corrections for one planning decision to read through without mutating shared state.

pub fn update_feedback(&self, key: &str, actual_selectivity: f64) -> bool

Update feedback

pub fn update_feedback_ratio(&self, key: &str, ratio: f64) -> bool

Update feedback from an estimated-vs-actual row ratio.

The ratio is the correction factor actual_rows / estimated_rows; returns false when the key has not been registered.

pub fn update_measured_ratio( &self, key: &str, ratio: f64, input_rows: u64, ) -> bool

Update feedback from a measured local-parameter ratio over a known number of input rows (the feedback loop’s write path).

Returns false when the key has not been registered; staged outliers still return true (the sample was recorded, just not applied yet).

pub fn remove_feedback_by_space(&self, space_prefix: &str) -> usize

Remove all feedback whose key starts with space_prefix (e.g. "myspace:"), returning the number of removed entries.

pub fn update_feedback_batch(&self, updates: &[(String, f64)])

Batch Update Feedback

pub fn get_feedback(&self, key: &str) -> Option<FeedbackDrivenSelectivity>

Obtain feedback information

pub fn get_all_keys(&self) -> Vec<String>

Obtain all feedback keys.

pub fn clear_all(&self)

Clear all feedback.

pub fn remove_feedback(&self, key: &str) -> Option<FeedbackDrivenSelectivity>

Remove feedback that meets specific criteria.

pub fn feedback_count(&self) -> usize

Number of feedback requests received

pub fn set_default_params( &mut self, alpha: f64, min_correction: f64, max_correction: f64, )

Set default parameters

Trait Implementations

impl Clone for SelectivityFeedbackManager

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SelectivityFeedbackManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SelectivityFeedbackManager

fn default() -> Self

Returns the “default value” for a type.