re_chunk 0.33.0

A chunk of Rerun data, encoded using Arrow. Used for logging, transport, storage and compute.
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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120

use re_chunk::Chunk;
use re_log_types::example_components::{MyColor, MyPoint, MyPoints};
use re_log_types::{AbsoluteTimeRange, TimelineName, build_frame_nr};

#[test]
fn out_of_order_timeline() {
    let chunk = Chunk::builder("my_entity")
        .with_archetype_auto_row(
            [build_frame_nr(30)],
            &MyPoints::new([MyPoint::new(1.0, 1.0)]).with_colors([MyColor(1)]),
        )
        .with_archetype_auto_row(
            [build_frame_nr(10)],
            &MyPoints::update_fields().with_colors([MyColor(2)]),
        )
        .with_archetype_auto_row(
            [build_frame_nr(20)],
            &MyPoints::new([MyPoint::new(2.0, 2.0)]),
        )
        .build()
        .unwrap();

    let timeline_frame_nr = TimelineName::new("frame_nr");
    let timeline = chunk.timelines().get(&timeline_frame_nr).unwrap();
    assert!(!timeline.is_sorted());
    assert_eq!(timeline.time_range(), AbsoluteTimeRange::new(10, 30));
    assert_eq!(
        timeline.time_range_per_component(chunk.components()),
        [
            (
                MyPoints::descriptor_points().component,
                AbsoluteTimeRange::new(20, 30)
            ),
            (
                MyPoints::descriptor_colors().component,
                AbsoluteTimeRange::new(10, 30)
            ),
        ]
        .into_iter()
        .collect()
    );
}

#[test]
fn in_order_forwards_timeline() {
    let chunk = Chunk::builder("my_entity")
        .with_archetype_auto_row(
            [build_frame_nr(10)],
            &MyPoints::update_fields().with_colors([MyColor(2)]),
        )
        .with_archetype_auto_row(
            [build_frame_nr(20)],
            &MyPoints::new([MyPoint::new(2.0, 2.0)]),
        )
        .with_archetype_auto_row(
            [build_frame_nr(30)],
            &MyPoints::new([MyPoint::new(1.0, 1.0)]).with_colors([MyColor(1)]),
        )
        .build()
        .unwrap();

    let timeline_frame_nr = TimelineName::new("frame_nr");
    let timeline = chunk.timelines().get(&timeline_frame_nr).unwrap();
    assert!(timeline.is_sorted());
    assert_eq!(timeline.time_range(), AbsoluteTimeRange::new(10, 30));
    assert_eq!(
        timeline.time_range_per_component(chunk.components()),
        [
            (
                MyPoints::descriptor_points().component,
                AbsoluteTimeRange::new(20, 30)
            ),
            (
                MyPoints::descriptor_colors().component,
                AbsoluteTimeRange::new(10, 30)
            ),
        ]
        .into_iter()
        .collect()
    );
}

#[test]
fn in_order_backwards_timeline() {
    let chunk = Chunk::builder("my_entity")
        .with_archetype_auto_row(
            [build_frame_nr(30)],
            &MyPoints::new([MyPoint::new(1.0, 1.0)]).with_colors([MyColor(1)]),
        )
        .with_archetype_auto_row(
            [build_frame_nr(20)],
            &MyPoints::new([MyPoint::new(2.0, 2.0)]),
        )
        .with_archetype_auto_row(
            [build_frame_nr(10)],
            &MyPoints::update_fields().with_colors([MyColor(2)]),
        )
        .build()
        .unwrap();

    let timeline_frame_nr = TimelineName::new("frame_nr");
    let timeline = chunk.timelines().get(&timeline_frame_nr).unwrap();
    assert!(!timeline.is_sorted());
    assert_eq!(timeline.time_range(), AbsoluteTimeRange::new(10, 30));
    assert_eq!(
        timeline.time_range_per_component(chunk.components()),
        [
            (
                MyPoints::descriptor_points().component,
                AbsoluteTimeRange::new(20, 30)
            ),
            (
                MyPoints::descriptor_colors().component,
                AbsoluteTimeRange::new(10, 30)
            ),
        ]
        .into_iter()
        .collect()
    );
}