fast-stats 0.1.1

Rust library for efficient calculation of statistics from streaming data
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

use std::time::{Instant, Duration};

use fast_stats::stats::stddev;
use fast_stats::fstats_float::Stats;

#[test]
fn stddev_stats_benchmark() {
    let vs: Vec<i32> = (0..200000).collect();
    let mut vs: Vec<f64> = vs.iter().map(|x| *x as f64).collect();
    let es: Vec<i32> = (200000..200010).collect();
    let es: Vec<f64> = es.iter().map(|x| *x as f64).collect();
    vs.extend(es);

    let mut i = 10;
    let mut elapsed_vec = vec![];
    while i > 0 {
        let now = Instant::now();
        stddev(&vs);
        let elapsed = now.elapsed();
        elapsed_vec.push(elapsed);
        i -= 1;
    }
    let total_elapsed: Duration = elapsed_vec.iter().sum();
    let avg_elapsed = total_elapsed.as_nanos() / 10;
    println!("Averaged elapsed time is {}", avg_elapsed) // ~11059856
}

#[test]
fn stddev_fstats_benchmark() {
    let mut vfs = Stats::new();
    let v: Vec<i32> = (0..200000).collect();
    let v: Vec<f64> = v.iter().map(|x| *x as f64).collect();
    vfs.push_vec(v);
    vfs.stddev();
    
    let v: Vec<i32> = (200000..200010).collect();
    let v: Vec<f64> = v.iter().map(|x| *x as f64).collect();
    vfs.push_vec(v);

    let mut i = 10;
    let mut elapsed_vec = vec![];
    while i > 0 {
        let now = Instant::now();
        vfs.stddev();
        let elapsed = now.elapsed();
        elapsed_vec.push(elapsed);
        i -= 1;
    }
    let total_elapsed: Duration = elapsed_vec.iter().sum();
    let avg_elapsed = total_elapsed.as_nanos() / 10;
    println!("Averaged elapsed time is {}", avg_elapsed) // ~49
    
}

#[test]
fn drain_stddev_stats_benchmark() {
    let vs: Vec<i32> = (0..2000010).collect();
    let mut vs: Vec<f64> = vs.iter().map(|x| *x as f64).collect();
    vs.drain(0..10);

    let mut i = 10;
    let mut elapsed_vec = vec![];
    while i > 0 {
        let now = Instant::now();
        stddev(&vs);
        let elapsed = now.elapsed();
        elapsed_vec.push(elapsed);
        i -= 1;
    }
    let total_elapsed: Duration = elapsed_vec.iter().sum();
    let avg_elapsed = total_elapsed.as_nanos() / 10;
    println!("Averaged elapsed time is {}", avg_elapsed) // ~98569335
}

#[test]
fn drain_stddev_fstats_benchmark() {
    let mut vfs = Stats::new();
    let v: Vec<i32> = (0..200010).collect();
    let v: Vec<f64> = v.iter().map(|x| *x as f64).collect();
    vfs.push_vec(v);
    vfs.stddev();
    vfs.drain(0..10);

    let mut i = 10;
    let mut elapsed_vec = vec![];
    while i > 0 {
        let now = Instant::now();
        vfs.stddev();
        let elapsed = now.elapsed();
        elapsed_vec.push(elapsed);
        i -= 1;
    }
    let total_elapsed: Duration = elapsed_vec.iter().sum();
    let avg_elapsed = total_elapsed.as_nanos() / 10;
    println!("Averaged elapsed time is {}", avg_elapsed) // ~49
    
}