Port TransportChunk to arrow-rs

Cargo.lock

@@ -5921,6 +5921,7 @@ dependencies = [
  "re_arrow_util",
  "re_chunk",
  "re_chunk_store",
+ "re_format_arrow",
  "re_log",
  "re_log_encoding",
  "re_log_types",
@@ -7322,6 +7323,7 @@ name = "rerun"
 version = "0.22.0-alpha.1+dev"
 dependencies = [
  "anyhow",
+ "arrow",
  "clap",
  "document-features",
  "env_logger",
@@ -7342,6 +7344,7 @@ dependencies = [
  "re_entity_db",
  "re_error",
  "re_format",
+ "re_format_arrow",
  "re_log",
  "re_log_encoding",
  "re_log_types",

crates/store/re_chunk/Cargo.toml

@@ -30,9 +30,6 @@ serde = [
   "re_types_core/serde",
 ]
 
-## Enable conversion to and from arrow-rs types
-arrow = ["arrow2/arrow"]
-
 
 [dependencies]
 

crates/store/re_chunk/src/chunk.rs

@@ -956,13 +956,29 @@ impl Chunk {
         }
     }
 
-    /// Unconditionally inserts an [`Arrow2ListArray`] as a component column.
+    /// Unconditionally inserts an [`ArrowListArray`] as a component column.
     ///
     /// Removes and replaces the column if it already exists.
     ///
     /// This will fail if the end result is malformed in any way -- see [`Self::sanity_check`].
     #[inline]
     pub fn add_component(
+        &mut self,
+        component_desc: ComponentDescriptor,
+        list_array: ArrowListArray,
+    ) -> ChunkResult<()> {
+        self.components
+            .insert_descriptor(component_desc, list_array);
+        self.sanity_check()
+    }
+
+    /// Unconditionally inserts an [`Arrow2ListArray`] as a component column.
+    ///
+    /// Removes and replaces the column if it already exists.
+    ///
+    /// This will fail if the end result is malformed in any way -- see [`Self::sanity_check`].
+    #[inline]
+    pub fn add_component_arrow2(
         &mut self,
         component_desc: ComponentDescriptor,
         list_array: Arrow2ListArray<i32>,

crates/store/re_chunk/src/lib.rs

@@ -6,7 +6,6 @@
 
 mod builder;
 mod chunk;
-pub mod concat_record_batches;
 mod helpers;
 mod id;
 mod iter;
@@ -21,9 +20,6 @@ mod transport;
 #[cfg(not(target_arch = "wasm32"))]
 mod batcher;
 
-#[cfg(feature = "arrow")]
-mod arrow;
-
 pub use self::builder::{ChunkBuilder, TimeColumnBuilder};
 pub use self::chunk::{
     Chunk, ChunkComponents, ChunkError, ChunkResult, TimeColumn, TimeColumnError,