SDK batching/revamp 1: impl DataTableBatcher

Cargo.toml

@@ -57,6 +57,7 @@ arrow2_convert = "0.4.2"
 cfg-if = "1.0"
 clap = "4.0"
 comfy-table = { version = "6.1", default-features = false }
+crossbeam = "0.8"
 ctrlc = { version = "3.0", features = ["termination"] }
 ecolor = "0.21.0"
 eframe = { version = "0.21.3", default-features = false }

crates/re_analytics/Cargo.toml

@@ -23,7 +23,7 @@ re_log.workspace = true
 
 # External dependencies:
 anyhow.workspace = true
-crossbeam = "0.8"
+crossbeam.workspace = true
 once_cell = "1.17"
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"

crates/re_log_types/Cargo.toml

@@ -91,8 +91,10 @@ serde_bytes = { version = "0.11", optional = true }
 
 # Native dependencies:
 [target.'cfg(not(target_arch = "wasm32"))'.dependencies]
+crossbeam.workspace = true
 puffin.workspace = true
 
 
 [dev-dependencies]
 rmp-serde = "1.1"
+similar-asserts = "1.4.2"

crates/re_log_types/src/data_row.rs

@@ -87,6 +87,13 @@ impl std::ops::IndexMut<usize> for DataCellRow {
     }
 }
 
+impl SizeBytes for DataCellRow {
+    #[inline]
+    fn heap_size_bytes(&self) -> u64 {
+        self.0.heap_size_bytes()
+    }
+}
+
 // ---
 
 /// A unique ID for a [`DataRow`].
@@ -325,6 +332,24 @@ impl DataRow {
     }
 }
 
+impl SizeBytes for DataRow {
+    fn heap_size_bytes(&self) -> u64 {
+        let Self {
+            row_id,
+            timepoint,
+            entity_path,
+            num_instances,
+            cells,
+        } = self;
+
+        row_id.heap_size_bytes()
+            + timepoint.heap_size_bytes()
+            + entity_path.heap_size_bytes()
+            + num_instances.heap_size_bytes()
+            + cells.heap_size_bytes()
+    }
+}
+
 impl DataRow {
     #[inline]
     pub fn row_id(&self) -> RowId {