chronix-analytics 0.7.0

Analytics engine for Chronix — preprocessing, forecasting, anomaly detection, multivariate analysis, model lifecycle, and streaming analytics on a SIMD/rayon CPU compute core
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

//! # Chronix Preprocessing Pipeline
//!
//! Gap detection, interpolation, smoothing, resampling, and clock drift
//! correction for time-series data — all operating on Arrow-compatible
//! `&[f64]` / `&[i64]` arrays with zero-copy where possible.
//!
//! ## Pipeline Order
//!
//! ```text
//! Raw data → Clock drift correction → Gap detection → Interpolation → Smoothing → Resampling
//! ```
//!
//! ## Interpolation Methods
//!
//! - `Linear` — linearly interpolated values between known points
//! - `Nearest` — nearest neighbor fill
//! - `CatmullRom` — Catmull-Rom spline (C1 local interpolation, requires ≥ 4 surrounding points)
//! - `Zero` — fill with 0.0
//! - `Forward` — last known value carried forward
//! - `Nocb` — next observation carried backward
//!
//! ## Smoothing Filters
//!
//! - `ExponentialSmoother` — single-pass EMA with configurable alpha
//! - `MovingAverageSmoother` — sliding window mean
//! - `WeightedMovingAverage` — custom weight vector

#![warn(missing_docs)]
#![deny(unsafe_code)]

mod clock_drift;
mod gap;
mod interpolation;
mod pipeline;
mod resampling;
mod smoothing;

pub mod arrow_adapters;
pub mod auto_features;
pub mod decomposition;
pub mod features;

pub use arrow_adapters::{
    ArrowPreprocessResult, arrow_interpolate, arrow_preprocess, arrow_smooth,
};
pub use auto_features::{AutoFeatureConfig, FeatureMatrix};
pub use clock_drift::{ClockDriftDetector, ClockDriftReport, ClockDriftStrategy};
pub use decomposition::{
    Decomposition, DecompositionError, SeasonalDecomposer, StlConfig, StlDecomposer, detect_period,
    detect_period_with_threshold, stl_decompose,
};
pub use features::{diff, ewm, lag, pct_change, rolling_corr, rolling_mean, rolling_std, zscore};
pub use gap::GapDetector;
pub use interpolation::{InterpolationError, Interpolator};
pub use pipeline::{PreprocessConfig, PreprocessError, PreprocessPipeline, PreprocessResult};
pub use resampling::{AggregationFn, ResampleConfig, Resampler};
pub use smoothing::{ExponentialSmoother, MovingAverageSmoother, Smoother, WeightedMovingAverage};