Struct Adwin 

pub struct Adwin { /* private fields */ }

ADWIN (Adaptive Windowing) drift detector.

Maintains a variable-length window and detects distribution changes by comparing the means of the window’s two halves. See the module documentation for the algorithm.

Examples

use rill_ml::drift::{Adwin, DriftDetector, DriftLevel};

let mut adwin = Adwin::default();

// Stable stream.
for _ in 0..100 {
    adwin.update(0.0).unwrap();
}
assert_eq!(adwin.level(), DriftLevel::None);

// Sudden shift. ADWIN's level is transient: after detecting drift and
// trimming the window, subsequent stable updates reset the level to
// None, so we check the level returned by each update.
let mut detected = false;
for _ in 0..100 {
    let level = adwin.update(5.0).unwrap();
    if level == DriftLevel::Drift {
        detected = true;
        break;
    }
}
assert!(detected);

Implementations

impl Adwin

pub fn new(config: AdwinConfig) -> Result<Self, RillError>

Create a new ADWIN detector with the given configuration.

Returns an error if:

• delta is not in (0, 1).
• warning_delta is not in (0, 1) or is less than delta.
• max_window is zero.
• min_samples is zero.

pub fn window_size(&self) -> usize

The number of values currently in the window.

pub fn window_mean(&self) -> f64

The mean of all values currently in the window, or 0.0 if empty.

pub const fn config(&self) -> &AdwinConfig

The configuration of this detector.

Trait Implementations

impl Clone for Adwin

fn clone(&self) -> Adwin

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Adwin

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

Formats the value using the given formatter.

impl Default for Adwin

fn default() -> Self

Returns the “default value” for a type.

impl DriftDetector for Adwin

fn update(&mut self, value: f64) -> Result<DriftLevel, RillError>

Update the detector with a new scalar observation.

fn detected(&self) -> bool

Returns true if the detector currently reports a confirmed drift.

fn warning(&self) -> bool

Returns true if the detector currently reports a warning.

fn level(&self) -> DriftLevel

The current drift level.

fn samples_seen(&self) -> u64

Number of observations incorporated so far.

fn reset(&mut self)

Reset the detector to its initial (no-data) state.

fn last_value(&self) -> f64

The detector-specific statistic value from the last update.