Initial work

Signed-off-by: Adam Gutglick <adam@spiraldb.com>

Author: AdamGS

encodings/parquet-variant/Cargo.toml

@@ -12,6 +12,7 @@ readme = { workspace = true }
 repository = { workspace = true }
 rust-version = { workspace = true }
 version = { workspace = true }
+publish = false
 
 [lints]
 workspace = true

encodings/parquet-variant/public-api.lock

@@ -3,15 +3,17 @@
 
 use std::hash::Hash;
 use std::hash::Hasher;
+use std::sync::Arc;
 
 use prost::Message;
 use vortex_array::ArrayEq;
 use vortex_array::ArrayHash;
 use vortex_array::ArrayRef;
 use vortex_array::ExecutionCtx;
-use vortex_array::ExecutionStep;
+use vortex_array::ExecutionResult;
 use vortex_array::IntoArray;
 use vortex_array::Precision;
+use vortex_array::arrays::VariantArray;
 use vortex_array::buffer::BufferHandle;
 use vortex_array::dtype::DType;
 use vortex_array::dtype::Nullability;
@@ -35,7 +37,7 @@ use vortex_session::VortexSession;
 use crate::array::ParquetVariantArray;
 
 /// VTable for [`ParquetVariantArray`].
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 pub struct ParquetVariant;
 
 impl ParquetVariant {
@@ -316,8 +318,11 @@ impl VTable for ParquetVariant {
         Ok(())
     }
 
-    fn execute(array: &Self::Array, _ctx: &mut ExecutionCtx) -> VortexResult<ExecutionStep> {
-        Ok(ExecutionStep::done(array.clone().into_array()))
+    fn execute(array: Arc<Self::Array>, _ctx: &mut ExecutionCtx) -> VortexResult<ExecutionResult> {
+        let nullability = array.dtype.nullability();
+        Ok(ExecutionResult::done(
+            VariantArray::new(array.as_ref().clone().into_array(), nullability).into_array(),
+        ))
     }
 }