introduce DataCell, retire ComponentBundle

Cargo.toml

@@ -59,16 +59,17 @@ ctrlc = { version = "3.0", features = ["termination"] }
 ecolor = "0.21.0"
 eframe = { version = "0.21.3", default-features = false }
 egui = "0.21.0"
+egui-wgpu = "0.21.0"
 egui_dock = "0.4"
 egui_extras = "0.21.0"
-egui-wgpu = "0.21.0"
 emath = "0.21.0"
 enumset = "1.0.12"
 epaint = "0.21.0"
 glam = "0.22"
 gltf = "1.1"
 half = "2.0"
 image = { version = "0.24", default-features = false }
+itertools = "0.10"
 lazy_static = "1.4"
 macaw = "0.18"
 mimalloc = "0.1.29"

crates/re_arrow_store/Cargo.toml

@@ -41,7 +41,7 @@ arrow2 = { workspace = true, features = [
 ] }
 document-features = "0.2"
 indent = "0.1"
-itertools = "0.10"
+itertools = { workspace = true }
 nohash-hasher = "0.2"
 parking_lot.workspace = true
 static_assertions = "1.1"

crates/re_arrow_store/benches/data_store.rs

@@ -166,7 +166,7 @@ fn insert_messages<'a>(
     msgs: impl Iterator<Item = &'a MsgBundle>,
 ) -> DataStore {
     let mut store = DataStore::new(cluster_key, config);
-    msgs.for_each(|msg_bundle| store.insert(msg_bundle).unwrap());
+    msgs.for_each(|msg_bundle| store.insert_row(msg_bundle).unwrap());
     store
 }
 

crates/re_arrow_store/examples/dump_dataframe.rs

@@ -29,48 +29,48 @@ fn main() {
         let bundle1 = test_bundle!(ent_path @ [
             build_frame_nr(1.into()), build_log_time(Time::now()),
         ] => [build_some_instances(2), build_some_rects(2)]);
-        store.insert(&bundle1).unwrap();
+        store.insert_row(&bundle1).unwrap();
     }
 
     for ent_path in &ent_paths {
         let bundle2 = test_bundle!(ent_path @ [
             build_frame_nr(2.into())
         ] => [build_some_instances(2), build_some_point2d(2)]);
-        store.insert(&bundle2).unwrap();
+        store.insert_row(&bundle2).unwrap();
         // Insert timelessly too!
         let bundle2 =
             test_bundle!(ent_path @ [] => [build_some_instances(2), build_some_point2d(2)]);
-        store.insert(&bundle2).unwrap();
+        store.insert_row(&bundle2).unwrap();
 
         let bundle3 = test_bundle!(ent_path @ [
             build_frame_nr(3.into()), build_log_time(Time::now()),
         ] => [build_some_instances_from(25..29), build_some_point2d(4)]);
-        store.insert(&bundle3).unwrap();
+        store.insert_row(&bundle3).unwrap();
         // Insert timelessly too!
         let bundle3 = test_bundle!(ent_path @ [] => [build_some_instances_from(25..29), build_some_point2d(4)]);
-        store.insert(&bundle3).unwrap();
+        store.insert_row(&bundle3).unwrap();
     }
 
     for ent_path in &ent_paths {
         let bundle4_1 = test_bundle!(ent_path @ [
             build_frame_nr(4.into()), build_log_time(Time::now()),
         ] => [build_some_instances_from(20..23), build_some_rects(3)]);
-        store.insert(&bundle4_1).unwrap();
+        store.insert_row(&bundle4_1).unwrap();
 
         let bundle4_15 = test_bundle!(ent_path @ [
             build_frame_nr(4.into()),
         ] => [build_some_instances_from(20..23), build_some_point2d(3)]);
-        store.insert(&bundle4_15).unwrap();
+        store.insert_row(&bundle4_15).unwrap();
 
         let bundle4_2 = test_bundle!(ent_path @ [
             build_frame_nr(4.into()), build_log_time(Time::now()),
         ] => [build_some_instances_from(25..28), build_some_rects(3)]);
-        store.insert(&bundle4_2).unwrap();
+        store.insert_row(&bundle4_2).unwrap();
 
         let bundle4_25 = test_bundle!(ent_path @ [
             build_frame_nr(4.into()), build_log_time(Time::now()),
         ] => [build_some_instances_from(25..28), build_some_point2d(3)]);
-        store.insert(&bundle4_25).unwrap();
+        store.insert_row(&bundle4_25).unwrap();
     }
 
     let df = store.to_dataframe();

crates/re_arrow_store/examples/latest_component.rs

@@ -21,10 +21,10 @@ fn main() {
     let ent_path = EntityPath::from("my/entity");
 
     let bundle = test_bundle!(ent_path @ [build_frame_nr(2.into())] => [build_some_rects(4)]);
-    store.insert(&bundle).unwrap();
+    store.insert_row(&bundle).unwrap();
 
     let bundle = test_bundle!(ent_path @ [build_frame_nr(3.into())] => [build_some_point2d(2)]);
-    store.insert(&bundle).unwrap();
+    store.insert_row(&bundle).unwrap();
 
     let timeline_frame_nr = Timeline::new("frame_nr", TimeType::Sequence);
 

crates/re_arrow_store/examples/latest_components.rs

@@ -20,10 +20,10 @@ fn main() {
     let ent_path = EntityPath::from("my/entity");
 
     let bundle = test_bundle!(ent_path @ [build_frame_nr(2.into())] => [build_some_rects(4)]);
-    store.insert(&bundle).unwrap();
+    store.insert_row(&bundle).unwrap();
 
     let bundle = test_bundle!(ent_path @ [build_frame_nr(3.into())] => [build_some_point2d(2)]);
-    store.insert(&bundle).unwrap();
+    store.insert_row(&bundle).unwrap();
 
     let timeline_frame_nr = Timeline::new("frame_nr", TimeType::Sequence);
     let df = latest_components(

crates/re_arrow_store/examples/range_components.rs

@@ -24,25 +24,25 @@ fn main() {
     let frame4 = 4.into();
 
     let bundle = test_bundle!(ent_path @ [build_frame_nr(frame1)] => [build_some_rects(2)]);
-    store.insert(&bundle).unwrap();
+    store.insert_row(&bundle).unwrap();
 
     let bundle = test_bundle!(ent_path @ [build_frame_nr(frame2)] => [build_some_point2d(2)]);
-    store.insert(&bundle).unwrap();
+    store.insert_row(&bundle).unwrap();
 
     let bundle = test_bundle!(ent_path @ [build_frame_nr(frame3)] => [build_some_point2d(4)]);
-    store.insert(&bundle).unwrap();
+    store.insert_row(&bundle).unwrap();
 
     let bundle = test_bundle!(ent_path @ [build_frame_nr(frame4)] => [build_some_rects(3)]);
-    store.insert(&bundle).unwrap();
+    store.insert_row(&bundle).unwrap();
 
     let bundle = test_bundle!(ent_path @ [build_frame_nr(frame4)] => [build_some_point2d(1)]);
-    store.insert(&bundle).unwrap();
+    store.insert_row(&bundle).unwrap();
 
     let bundle = test_bundle!(ent_path @ [build_frame_nr(frame4)] => [build_some_rects(3)]);
-    store.insert(&bundle).unwrap();
+    store.insert_row(&bundle).unwrap();
 
     let bundle = test_bundle!(ent_path @ [build_frame_nr(frame4)] => [build_some_point2d(3)]);
-    store.insert(&bundle).unwrap();
+    store.insert_row(&bundle).unwrap();
 
     let timeline_frame_nr = Timeline::new("frame_nr", TimeType::Sequence);
     let query = RangeQuery::new(timeline_frame_nr, TimeRange::new(2.into(), 4.into()));