Array VTables

benchmarks/compress-bench/src/lib.rs

@@ -23,7 +23,7 @@ pub fn chunked_to_vec_record_batch(
             // TODO(connor)[ListView]: The rust Parquet implementation does not support writing
             // `ListView` to Parquet files yet.
             let converted_array = recursive_list_from_list_view(array.clone())?;
-            Ok(RecordBatch::try_from(converted_array.as_ref())?)
+            Ok(RecordBatch::try_from(&converted_array)?)
         })
         .collect::<anyhow::Result<Vec<_>>>()?;
 

benchmarks/compress-bench/src/vortex.rs

@@ -12,6 +12,7 @@ use async_trait::async_trait;
 use bytes::Bytes;
 use futures::StreamExt;
 use futures::pin_mut;
+use vortex::array::IntoArray;
 use vortex::file::OpenOptionsSessionExt;
 use vortex::file::WriteOptionsSessionExt;
 use vortex_bench::Format;
@@ -37,7 +38,7 @@ impl Compressor for VortexCompressor {
         let mut cursor = Cursor::new(&mut buf);
         SESSION
             .write_options()
-            .write(&mut cursor, uncompressed.to_array_stream())
+            .write(&mut cursor, uncompressed.into_array().to_array_stream())
             .await?;
         let elapsed = start.elapsed();
 
@@ -51,7 +52,7 @@ impl Compressor for VortexCompressor {
         let mut cursor = Cursor::new(&mut buf);
         SESSION
             .write_options()
-            .write(&mut cursor, uncompressed.to_array_stream())
+            .write(&mut cursor, uncompressed.into_array().to_array_stream())
             .await?;
 
         // Now decompress