use cubecl::prelude::*;
use cubecl_core as cubecl;
#[derive(Default, Copy, Clone, Debug)]
pub struct BinStats {
pub count: usize,
pub n_runs: usize, }
pub fn calculate_bin_stats<E: Numeric>(
numbers: &[E],
number_of_bins: usize,
low: f32,
high: f32,
) -> Vec<BinStats> {
let range = (high - low) / number_of_bins as f32;
let mut output: Vec<BinStats> = (0..number_of_bins).map(|_| Default::default()).collect();
let mut initialized = false;
let mut current_runs = number_of_bins; for number in numbers {
let num = number.to_f32().unwrap();
if num < low || num > high {
continue;
}
let index = (f32::floor((num - low) / range) as usize).min(number_of_bins - 1);
output[index].count += 1;
if initialized && index != current_runs {
output[current_runs].n_runs += 1;
}
initialized = true;
current_runs = index;
}
output[current_runs].n_runs += 1;
output
}
pub fn assert_mean_approx_equal<E: Numeric>(data: &[E], expected_mean: f32) {
let mut sum = 0.;
for elem in data {
let elem = elem.to_f32().unwrap();
sum += elem;
}
let mean = sum / (data.len() as f32);
let mut sum = 0.0;
for elem in data {
let elem = elem.to_f32().unwrap();
let d = elem - mean;
sum += d * d;
}
let var = sum / ((data.len() - 1) as f32);
let std = var.sqrt();
let z = (mean - expected_mean).abs() / std;
assert!(
z < 3.,
"Uniform RNG validation failed: mean={mean}, expected mean={expected_mean}, std={std}",
);
}
pub fn assert_normal_respects_68_95_99_rule<E: Numeric>(data: &[E], mu: f32, s: f32) {
let stats = calculate_bin_stats(data, 6, mu - 3. * s, mu + 3. * s);
let assert_approx_eq = |count, percent| {
let expected = percent * data.len() as f32 / 100.;
assert!(f32::abs(count as f32 - expected) < 2000.);
};
assert_approx_eq(stats[0].count, 2.1);
assert_approx_eq(stats[1].count, 13.6);
assert_approx_eq(stats[2].count, 34.1);
assert_approx_eq(stats[3].count, 34.1);
assert_approx_eq(stats[4].count, 13.6);
assert_approx_eq(stats[5].count, 2.1);
}
pub fn assert_number_of_1_proportional_to_prob<E: Numeric>(data: &[E], prob: f32) {
let bin_stats = calculate_bin_stats(data, 2, 0., 1.1);
assert!(f32::abs((bin_stats[1].count as f32 / data.len() as f32) - prob) < 0.05);
}
pub fn assert_wald_wolfowitz_runs_test<E: Numeric>(data: &[E], bins_low: f32, bins_high: f32) {
let stats = calculate_bin_stats(data, 2, bins_low, bins_high);
let n_0 = stats[0].count as f32;
let n_1 = stats[1].count as f32;
let n_runs = (stats[0].n_runs + stats[1].n_runs) as f32;
let expectation = (2. * n_0 * n_1) / (n_0 + n_1) + 1.0;
let variance = ((2. * n_0 * n_1) * (2. * n_0 * n_1 - n_0 - n_1))
/ ((n_0 + n_1).powf(2.) * (n_0 + n_1 - 1.));
let z = (n_runs - expectation) / f32::sqrt(variance);
assert!(z.abs() < 2.6, "z: {z}, var: {variance}");
}
pub fn assert_at_least_one_value_per_bin<E: Numeric>(
data: &[E],
number_of_bins: usize,
bins_low: f32,
bins_high: f32,
) {
let stats = calculate_bin_stats(data, number_of_bins, bins_low, bins_high);
assert!(stats[0].count >= 1);
assert!(stats[1].count >= 1);
assert!(stats[2].count >= 1);
}