save

spiraldb · Jan 21, 2025 · c8d4b6d · c8d4b6d
1 parent 461a3ec
commit c8d4b6d
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 1 deletion.
diff --git a/vortex-array/src/array/primitive/mod.rs b/vortex-array/src/array/primitive/mod.rs
@@ -199,6 +199,7 @@ impl PrimitiveArray {
         }
         let length = self.len();
         let raw_slice = self.byte_buffer().as_slice();
+        println!("raw_slice.len() = {} ptype = {}", raw_slice.len(), T::PTYPE);
         debug_assert_eq!(raw_slice.len() / size_of::<T>(), length);
         // SAFETY: alignment of Buffer is checked on construction
         unsafe { std::slice::from_raw_parts(raw_slice.as_ptr().cast(), length) }

diff --git a/vortex-array/src/array/struct_/compute.rs b/vortex-array/src/array/struct_/compute.rs
@@ -35,7 +35,9 @@ impl ScalarAtFn<StructArray> for StructEncoding {
             array.dtype().clone(),
             array
                 .children()
-                .map(|field| scalar_at(&field, index))
+                .enumerate()
+                .inspect(|(idx, _)| println!("scalar @ for field {idx}"))
+                .map(|(_, field)| scalar_at(&field, index))
                 .try_collect()?,
         ))
     }

diff --git a/vortex-array/src/array/varbin/mod.rs b/vortex-array/src/array/varbin/mod.rs
@@ -190,6 +190,7 @@ impl VarBinArray {
         Ok(PrimitiveArray::maybe_from(self.offsets())
             .map(|p| {
                 match_each_native_ptype!(p.ptype(), |$P| {
+                    println!("using offset ptype {}", $P::PTYPE);
                     p.as_slice::<$P>()[index].as_()
                 })
             })

diff --git a/vortex-array/src/data/mod.rs b/vortex-array/src/data/mod.rs
@@ -96,6 +96,7 @@ impl ArrayData {
 
         // Parse the array metadata
         let metadata = encoding.load_metadata(array.as_fb().metadata().map(|v| v.bytes()))?;
+        println!("metadata = {:?}", metadata);
 
         let view = ViewedArrayData {
             encoding,