tsz-compress 1.1.4

Delta-delta, Delta compression for time series 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

use tsz_compress::prelude::*;

extern crate alloc;

#[derive(Debug, Copy, Clone, CompressV2, DecompressV2)]
pub struct TestRow {
    t: i64,
    a: i8,
    b: i16,
    #[tsz(delta = "i32")]
    c: i32,
}

fn main() {
    let row = TestRow {
        t: 0,
        a: 1,
        b: 2,
        c: 3,
    };

    // Initialize the compressor
    let mut compressor = compress::TestRowCompressorImpl::new(128);

    // Compress row
    for _ in 0..10 {
        compressor.compress(row);
    }

    // Finalize the compression
    let bytes = compressor.finish();

    // Initialize the decompressor
    let mut decompressor = decompress::TestRowDecompressorImpl::new();

    // Decompress the bytes into columnar buffers in the decompressor
    decompressor.decompress(&bytes).unwrap();

    // Assert that the decompressed data matches the original
    assert_eq!(decompressor.col_a(), vec![row.a; 10]);

    // Rotate the decompressed data into rows
    decompressor.rows().iter().for_each(|x| {
        assert_eq!(row.t, x.t);
        assert_eq!(row.a, x.a);
        assert_eq!(row.b, x.b);
        assert_eq!(row.c, x.c);
    });
}