Remove operators

Signed-off-by: Nicholas Gates <[email protected]>

Author: gatesn

encodings/alp/src/alp/array.rs

@@ -64,7 +64,6 @@ impl VTable for ALPVTable {
     type VisitorVTable = Self;
     type ComputeVTable = NotSupported;
     type EncodeVTable = Self;
-    type OperatorVTable = NotSupported;
 
     fn id(&self) -> ArrayId {
         ArrayId::new_ref("vortex.alp")
@@ -141,17 +140,17 @@ impl VTable for ALPVTable {
         )
     }
 
-    fn execute(array: &ALPArray, ctx: &mut dyn ExecutionCtx) -> VortexResult<Vector> {
-        let encoded_vector = array.encoded().execute_batch(ctx)?;
+    fn execute(array: &ALPArray, ctx: &mut ExecutionCtx) -> VortexResult<Vector> {
+        let encoded_vector = array.encoded().execute(ctx)?;
 
         let patches_vectors = if let Some(patches) = array.patches() {
             Some((
-                patches.indices().execute_batch(ctx)?,
-                patches.values().execute_batch(ctx)?,
+                patches.indices().execute(ctx)?,
+                patches.values().execute(ctx)?,
                 patches
                     .chunk_offsets()
                     .as_ref()
-                    .map(|co| co.execute_batch(ctx))
+                    .map(|co| co.execute(ctx))
                     .transpose()?,
             ))
         } else {

encodings/alp/src/alp_rd/array.rs

@@ -77,7 +77,6 @@ impl VTable for ALPRDVTable {
     type VisitorVTable = Self;
     type ComputeVTable = NotSupported;
     type EncodeVTable = Self;
-    type OperatorVTable = NotSupported;
 
     fn id(&self) -> ArrayId {
         ArrayId::new_ref("vortex.alprd")

encodings/bytebool/src/array.rs

@@ -54,7 +54,6 @@ impl VTable for ByteBoolVTable {
     type VisitorVTable = Self;
     type ComputeVTable = NotSupported;
     type EncodeVTable = NotSupported;
-    type OperatorVTable = NotSupported;
 
     fn id(&self) -> ArrayId {
         ArrayId::new_ref("vortex.bytebool")

encodings/datetime-parts/src/array.rs

@@ -82,7 +82,6 @@ impl VTable for DateTimePartsVTable {
     type VisitorVTable = Self;
     type ComputeVTable = NotSupported;
     type EncodeVTable = Self;
-    type OperatorVTable = NotSupported;
 
     fn id(&self) -> ArrayId {
         ArrayId::new_ref("vortex.datetimeparts")

encodings/decimal-byte-parts/src/decimal_byte_parts/mod.rs

@@ -69,7 +69,6 @@ impl VTable for DecimalBytePartsVTable {
     type VisitorVTable = Self;
     type ComputeVTable = NotSupported;
     type EncodeVTable = NotSupported;
-    type OperatorVTable = NotSupported;
 
     fn id(&self) -> ArrayId {
         ArrayId::new_ref("vortex.decimal_byte_parts")

encodings/fastlanes/src/bitpacking/vtable/mod.rs

@@ -60,7 +60,6 @@ impl VTable for BitPackedVTable {
     type VisitorVTable = Self;
     type ComputeVTable = NotSupported;
     type EncodeVTable = Self;
-    type OperatorVTable = NotSupported;
 
     fn id(&self) -> ArrayId {
         ArrayId::new_ref("fastlanes.bitpacked")
@@ -173,7 +172,7 @@ impl VTable for BitPackedVTable {
         )
     }
 
-    fn execute(array: &BitPackedArray, _ctx: &mut dyn ExecutionCtx) -> VortexResult<Vector> {
+    fn execute(array: &BitPackedArray, _ctx: &mut ExecutionCtx) -> VortexResult<Vector> {
         Ok(unpack_to_primitive_vector(array).freeze().into())
     }
 }

encodings/fastlanes/src/delta/vtable/mod.rs

@@ -50,7 +50,6 @@ impl VTable for DeltaVTable {
     type VisitorVTable = Self;
     type ComputeVTable = NotSupported;
     type EncodeVTable = NotSupported;
-    type OperatorVTable = NotSupported;
 
     fn id(&self) -> ArrayId {
         ArrayId::new_ref("fastlanes.delta")

encodings/fastlanes/src/for/vtable/mod.rs

@@ -4,8 +4,6 @@
 use std::fmt::Debug;
 use std::fmt::Formatter;
 
-use vortex_array::DeserializeMetadata;
-use vortex_array::SerializeMetadata;
 use vortex_array::serde::ArrayChildren;
 use vortex_array::vtable;
 use vortex_array::vtable::ArrayId;
@@ -14,10 +12,12 @@ use vortex_array::vtable::ArrayVTableExt;
 use vortex_array::vtable::NotSupported;
 use vortex_array::vtable::VTable;
 use vortex_array::vtable::ValidityVTableFromChild;
+use vortex_array::DeserializeMetadata;
+use vortex_array::SerializeMetadata;
 use vortex_buffer::BufferHandle;
 use vortex_dtype::DType;
-use vortex_error::VortexResult;
 use vortex_error::vortex_bail;
+use vortex_error::VortexResult;
 use vortex_scalar::Scalar;
 use vortex_scalar::ScalarValue;
 
@@ -45,7 +45,6 @@ impl VTable for FoRVTable {
     type VisitorVTable = Self;
     type ComputeVTable = NotSupported;
     type EncodeVTable = Self;
-    type OperatorVTable = Self;
 
     fn id(&self) -> ArrayId {
         ArrayId::new_ref("fastlanes.for")

encodings/fastlanes/src/rle/vtable/mod.rs

@@ -2,7 +2,6 @@
 // SPDX-FileCopyrightText: Copyright the Vortex contributors
 
 use prost::Message;
-use vortex_array::ProstMetadata;
 use vortex_array::serde::ArrayChildren;
 use vortex_array::vtable;
 use vortex_array::vtable::ArrayId;
@@ -11,6 +10,7 @@ use vortex_array::vtable::ArrayVTableExt;
 use vortex_array::vtable::NotSupported;
 use vortex_array::vtable::VTable;
 use vortex_array::vtable::ValidityVTableFromChildSliceHelper;
+use vortex_array::ProstMetadata;
 use vortex_buffer::BufferHandle;
 use vortex_dtype::DType;
 use vortex_dtype::Nullability;
@@ -56,7 +56,6 @@ impl VTable for RLEVTable {
     type VisitorVTable = Self;
     type ComputeVTable = NotSupported;
     type EncodeVTable = Self;
-    type OperatorVTable = NotSupported;
 
     fn id(&self) -> ArrayId {
         ArrayId::new_ref("fastlanes.rle")

encodings/fsst/src/array.rs

@@ -76,7 +76,6 @@ impl VTable for FSSTVTable {
     type VisitorVTable = Self;
     type ComputeVTable = NotSupported;
     type EncodeVTable = Self;
-    type OperatorVTable = NotSupported;
 
     fn id(&self) -> ArrayId {
         ArrayId::new_ref("vortex.fsst")