break: clean up compute

encodings/alp/src/alp/compute/cast.rs

@@ -4,7 +4,7 @@
 use vortex_array::ArrayRef;
 use vortex_array::IntoArray;
 use vortex_array::builtins::ArrayBuiltins;
-use vortex_array::compute::CastReduce;
+use vortex_array::expr::CastReduce;
 use vortex_array::patches::Patches;
 use vortex_dtype::DType;
 use vortex_error::VortexResult;

encodings/alp/src/alp/compute/mask.rs

@@ -4,8 +4,8 @@
 use vortex_array::ArrayRef;
 use vortex_array::ExecutionCtx;
 use vortex_array::builtins::ArrayBuiltins;
-use vortex_array::compute::MaskKernel;
-use vortex_array::compute::MaskReduce;
+use vortex_array::expr::MaskKernel;
+use vortex_array::expr::MaskReduce;
 use vortex_array::validity::Validity;
 use vortex_error::VortexResult;
 

encodings/alp/src/alp/rules.rs

@@ -4,11 +4,11 @@
 use vortex_array::arrays::FilterExecuteAdaptor;
 use vortex_array::arrays::SliceExecuteAdaptor;
 use vortex_array::arrays::TakeExecuteAdaptor;
-use vortex_array::compute::CastReduceAdaptor;
-use vortex_array::compute::MaskExecuteAdaptor;
-use vortex_array::compute::MaskReduceAdaptor;
 use vortex_array::expr::BetweenReduceAdaptor;
+use vortex_array::expr::CastReduceAdaptor;
 use vortex_array::expr::CompareExecuteAdaptor;
+use vortex_array::expr::MaskExecuteAdaptor;
+use vortex_array::expr::MaskReduceAdaptor;
 use vortex_array::kernel::ParentKernelSet;
 use vortex_array::optimizer::rules::ParentRuleSet;
 

encodings/alp/src/alp_rd/compute/cast.rs

@@ -4,7 +4,7 @@
 use vortex_array::ArrayRef;
 use vortex_array::IntoArray;
 use vortex_array::builtins::ArrayBuiltins;
-use vortex_array::compute::CastReduce;
+use vortex_array::expr::CastReduce;
 use vortex_dtype::DType;
 use vortex_error::VortexResult;
 

encodings/alp/src/alp_rd/compute/mask.rs

@@ -4,9 +4,9 @@
 use vortex_array::ArrayRef;
 use vortex_array::IntoArray;
 use vortex_array::arrays::ScalarFnArrayExt;
-use vortex_array::compute::MaskReduce;
 use vortex_array::expr::EmptyOptions;
 use vortex_array::expr::Mask as MaskExpr;
+use vortex_array::expr::MaskReduce;
 use vortex_error::VortexResult;
 
 use crate::ALPRDArray;

encodings/alp/src/alp_rd/rules.rs

@@ -1,8 +1,8 @@
 // SPDX-License-Identifier: Apache-2.0
 // SPDX-FileCopyrightText: Copyright the Vortex contributors
 
-use vortex_array::compute::CastReduceAdaptor;
-use vortex_array::compute::MaskReduceAdaptor;
+use vortex_array::expr::CastReduceAdaptor;
+use vortex_array::expr::MaskReduceAdaptor;
 use vortex_array::optimizer::rules::ParentRuleSet;
 
 use crate::alp_rd::ALPRDVTable;

encodings/bytebool/src/compute.rs

@@ -8,8 +8,8 @@ use vortex_array::ExecutionCtx;
 use vortex_array::IntoArray;
 use vortex_array::ToCanonical;
 use vortex_array::arrays::TakeExecute;
-use vortex_array::compute::CastReduce;
-use vortex_array::compute::MaskReduce;
+use vortex_array::expr::CastReduce;
+use vortex_array::expr::MaskReduce;
 use vortex_array::validity::Validity;
 use vortex_array::vtable::ValidityHelper;
 use vortex_dtype::DType;

encodings/bytebool/src/rules.rs

@@ -2,8 +2,8 @@
 // SPDX-FileCopyrightText: Copyright the Vortex contributors
 
 use vortex_array::arrays::SliceReduceAdaptor;
-use vortex_array::compute::CastReduceAdaptor;
-use vortex_array::compute::MaskReduceAdaptor;
+use vortex_array::expr::CastReduceAdaptor;
+use vortex_array::expr::MaskReduceAdaptor;
 use vortex_array::optimizer::rules::ParentRuleSet;
 
 use crate::ByteBoolVTable;

encodings/datetime-parts/src/compute/cast.rs

@@ -5,7 +5,7 @@ use vortex_array::Array;
 use vortex_array::ArrayRef;
 use vortex_array::IntoArray;
 use vortex_array::builtins::ArrayBuiltins;
-use vortex_array::compute::CastReduce;
+use vortex_array::expr::CastReduce;
 use vortex_dtype::DType;
 use vortex_error::VortexResult;
 

encodings/datetime-parts/src/compute/compare.rs

@@ -8,10 +8,10 @@ use vortex_array::IntoArray;
 use vortex_array::arrays::ConstantArray;
 use vortex_array::builtins::ArrayBuiltins;
 use vortex_array::compute::Operator;
-use vortex_array::compute::and_kleene;
 use vortex_array::compute::compare;
-use vortex_array::compute::or_kleene;
 use vortex_array::expr::CompareKernel;
+use vortex_array::expr::and_kleene;
+use vortex_array::expr::or_kleene;
 use vortex_array::scalar::Scalar;
 use vortex_dtype::DType;
 use vortex_dtype::Nullability;

encodings/datetime-parts/src/compute/mask.rs

@@ -4,7 +4,7 @@
 use vortex_array::ArrayRef;
 use vortex_array::IntoArray;
 use vortex_array::builtins::ArrayBuiltins;
-use vortex_array::compute::MaskReduce;
+use vortex_array::expr::MaskReduce;
 use vortex_error::VortexResult;
 
 use crate::DateTimePartsArray;

encodings/datetime-parts/src/compute/rules.rs

@@ -13,10 +13,10 @@ use vortex_array::arrays::FilterVTable;
 use vortex_array::arrays::ScalarFnArray;
 use vortex_array::arrays::SliceReduceAdaptor;
 use vortex_array::builtins::ArrayBuiltins;
-use vortex_array::compute::CastReduceAdaptor;
-use vortex_array::compute::MaskReduceAdaptor;
 use vortex_array::expr::Between;
 use vortex_array::expr::Binary;
+use vortex_array::expr::CastReduceAdaptor;
+use vortex_array::expr::MaskReduceAdaptor;
 use vortex_array::optimizer::ArrayOptimizer;
 use vortex_array::optimizer::rules::ArrayParentReduceRule;
 use vortex_array::optimizer::rules::ParentRuleSet;

encodings/decimal-byte-parts/src/decimal_byte_parts/compute/cast.rs

@@ -5,7 +5,7 @@ use vortex_array::Array;
 use vortex_array::ArrayRef;
 use vortex_array::IntoArray;
 use vortex_array::builtins::ArrayBuiltins;
-use vortex_array::compute::CastReduce;
+use vortex_array::expr::CastReduce;
 use vortex_dtype::DType;
 use vortex_error::VortexResult;
 

encodings/decimal-byte-parts/src/decimal_byte_parts/compute/mask.rs

@@ -4,9 +4,9 @@
 use vortex_array::ArrayRef;
 use vortex_array::IntoArray;
 use vortex_array::arrays::ScalarFnArrayExt;
-use vortex_array::compute::MaskReduce;
 use vortex_array::expr::EmptyOptions;
 use vortex_array::expr::Mask as MaskExpr;
+use vortex_array::expr::MaskReduce;
 use vortex_error::VortexResult;
 
 use crate::DecimalBytePartsArray;

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

@@ -8,8 +8,8 @@ use vortex_array::arrays::FilterArray;
 use vortex_array::arrays::FilterReduceAdaptor;
 use vortex_array::arrays::FilterVTable;
 use vortex_array::arrays::SliceReduceAdaptor;
-use vortex_array::compute::CastReduceAdaptor;
-use vortex_array::compute::MaskReduceAdaptor;
+use vortex_array::expr::CastReduceAdaptor;
+use vortex_array::expr::MaskReduceAdaptor;
 use vortex_array::optimizer::rules::ArrayParentReduceRule;
 use vortex_array::optimizer::rules::ParentRuleSet;
 use vortex_error::VortexResult;

encodings/fastlanes/benches/compute_between.rs

@@ -72,12 +72,11 @@ mod primitive {
     use vortex_array::VortexSessionExecute;
     use vortex_array::arrays::ConstantArray;
     use vortex_array::builtins::ArrayBuiltins;
-    use vortex_array::compute::BooleanOperator;
     use vortex_array::compute::Operator;
-    use vortex_array::compute::boolean;
     use vortex_array::compute::compare;
     use vortex_array::expr::BetweenOptions;
     use vortex_array::expr::StrictComparison::NonStrict;
+    use vortex_array::expr::and_kleene;
     use vortex_dtype::NativePType;
     use vortex_error::VortexExpect;
 
@@ -98,24 +97,26 @@ mod primitive {
         let mut rng = StdRng::seed_from_u64(0);
         let arr = generate_primitive_array::<T>(&mut rng, len);
 
-        bencher.with_inputs(|| &arr).bench_refs(|arr| {
-            boolean(
-                &compare(
-                    arr.as_ref(),
-                    ConstantArray::new(min, arr.len()).as_ref(),
-                    Operator::Gte,
-                )
-                .vortex_expect(""),
-                &compare(
-                    arr.as_ref(),
-                    ConstantArray::new(max, arr.len()).as_ref(),
-                    Operator::Lt,
+        bencher
+            .with_inputs(|| (&arr, LEGACY_SESSION.create_execution_ctx()))
+            .bench_refs(|(arr, ctx)| {
+                and_kleene(
+                    &compare(
+                        arr.as_ref(),
+                        ConstantArray::new(min, arr.len()).as_ref(),
+                        Operator::Gte,
+                    )
+                    .vortex_expect(""),
+                    &compare(
+                        arr.as_ref(),
+                        ConstantArray::new(max, arr.len()).as_ref(),
+                        Operator::Lt,
+                    )
+                    .vortex_expect(""),
                 )
-                .vortex_expect(""),
-                BooleanOperator::And,
-            )
-            .vortex_expect("")
-        })
+                .vortex_expect("")
+                .execute::<RecursiveCanonical>(ctx)
+            })
     }
 
     #[divan::bench(
@@ -162,12 +163,11 @@ mod bitpack {
     use vortex_array::VortexSessionExecute;
     use vortex_array::arrays::ConstantArray;
     use vortex_array::builtins::ArrayBuiltins;
-    use vortex_array::compute::BooleanOperator;
     use vortex_array::compute::Operator;
-    use vortex_array::compute::boolean;
     use vortex_array::compute::compare;
     use vortex_array::expr::BetweenOptions;
     use vortex_array::expr::StrictComparison::NonStrict;
+    use vortex_array::expr::and_kleene;
     use vortex_dtype::NativePType;
     use vortex_error::VortexExpect;
 
@@ -188,23 +188,27 @@ mod bitpack {
         let mut rng = StdRng::seed_from_u64(0);
         let arr = generate_bit_pack_primitive_array::<T>(&mut rng, len);
 
-        bencher.with_inputs(|| &arr).bench_refs(|arr| {
-            boolean(
-                &compare(
-                    arr.as_ref(),
-                    ConstantArray::new(min, arr.len()).as_ref(),
-                    Operator::Gte,
-                )
-                .vortex_expect(""),
-                &compare(
-                    arr.as_ref(),
-                    ConstantArray::new(max, arr.len()).as_ref(),
-                    Operator::Lt,
+        bencher
+            .with_inputs(|| (&arr, LEGACY_SESSION.create_execution_ctx()))
+            .bench_refs(|(arr, ctx)| {
+                and_kleene(
+                    &compare(
+                        arr.as_ref(),
+                        ConstantArray::new(min, arr.len()).as_ref(),
+                        Operator::Gte,
+                    )
+                    .vortex_expect(""),
+                    &compare(
+                        arr.as_ref(),
+                        ConstantArray::new(max, arr.len()).as_ref(),
+                        Operator::Lt,
+                    )
+                    .vortex_expect(""),
                 )
-                .vortex_expect(""),
-                BooleanOperator::And,
-            )
-        })
+                .unwrap()
+                .execute::<RecursiveCanonical>(ctx)
+                .unwrap()
+            })
     }
 
     #[divan::bench(
@@ -251,12 +255,11 @@ mod alp {
     use vortex_array::VortexSessionExecute;
     use vortex_array::arrays::ConstantArray;
     use vortex_array::builtins::ArrayBuiltins;
-    use vortex_array::compute::BooleanOperator;
     use vortex_array::compute::Operator;
-    use vortex_array::compute::boolean;
     use vortex_array::compute::compare;
     use vortex_array::expr::BetweenOptions;
     use vortex_array::expr::StrictComparison::NonStrict;
+    use vortex_array::expr::and_kleene;
     use vortex_dtype::NativePType;
     use vortex_error::VortexExpect;
 
@@ -277,23 +280,27 @@ mod alp {
         let mut rng = StdRng::seed_from_u64(0);
         let arr = generate_alp_bit_pack_primitive_array::<T>(&mut rng, len);
 
-        bencher.with_inputs(|| &arr).bench_refs(|arr| {
-            boolean(
-                &compare(
-                    arr.as_ref(),
-                    ConstantArray::new(min, arr.len()).as_ref(),
-                    Operator::Gte,
-                )
-                .vortex_expect(""),
-                &compare(
-                    arr.as_ref(),
-                    ConstantArray::new(max, arr.len()).as_ref(),
-                    Operator::Lt,
+        bencher
+            .with_inputs(|| (&arr, LEGACY_SESSION.create_execution_ctx()))
+            .bench_refs(|(arr, ctx)| {
+                and_kleene(
+                    &compare(
+                        arr.as_ref(),
+                        ConstantArray::new(min, arr.len()).as_ref(),
+                        Operator::Gte,
+                    )
+                    .vortex_expect(""),
+                    &compare(
+                        arr.as_ref(),
+                        ConstantArray::new(max, arr.len()).as_ref(),
+                        Operator::Lt,
+                    )
+                    .vortex_expect(""),
                 )
-                .vortex_expect(""),
-                BooleanOperator::And,
-            )
-        })
+                .unwrap()
+                .execute::<RecursiveCanonical>(ctx)
+                .unwrap()
+            })
     }
 
     #[divan::bench(

encodings/fastlanes/src/bitpacking/compute/cast.rs

@@ -4,7 +4,7 @@
 use vortex_array::ArrayRef;
 use vortex_array::IntoArray;
 use vortex_array::builtins::ArrayBuiltins;
-use vortex_array::compute::CastReduce;
+use vortex_array::expr::CastReduce;
 use vortex_array::patches::Patches;
 use vortex_array::vtable::ValidityHelper;
 use vortex_dtype::DType;

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

@@ -1,7 +1,7 @@
 // SPDX-License-Identifier: Apache-2.0
 // SPDX-FileCopyrightText: Copyright the Vortex contributors
 
-use vortex_array::compute::CastReduceAdaptor;
+use vortex_array::expr::CastReduceAdaptor;
 use vortex_array::optimizer::rules::ParentRuleSet;
 
 use crate::BitPackedVTable;

encodings/fastlanes/src/delta/compute/cast.rs

@@ -4,7 +4,7 @@
 use vortex_array::ArrayRef;
 use vortex_array::IntoArray;
 use vortex_array::builtins::ArrayBuiltins;
-use vortex_array::compute::CastReduce;
+use vortex_array::expr::CastReduce;
 use vortex_dtype::DType;
 use vortex_dtype::Nullability::NonNullable;
 use vortex_error::VortexResult;

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

@@ -2,7 +2,7 @@
 // SPDX-FileCopyrightText: Copyright the Vortex contributors
 
 use vortex_array::arrays::SliceReduceAdaptor;
-use vortex_array::compute::CastReduceAdaptor;
+use vortex_array::expr::CastReduceAdaptor;
 use vortex_array::optimizer::rules::ParentRuleSet;
 
 use crate::delta::vtable::DeltaVTable;

encodings/fastlanes/src/for/compute/cast.rs

@@ -4,7 +4,7 @@
 use vortex_array::ArrayRef;
 use vortex_array::IntoArray;
 use vortex_array::builtins::ArrayBuiltins;
-use vortex_array::compute::CastReduce;
+use vortex_array::expr::CastReduce;
 use vortex_dtype::DType;
 use vortex_error::VortexResult;
 

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

@@ -8,7 +8,7 @@ use vortex_array::arrays::FilterArray;
 use vortex_array::arrays::FilterReduceAdaptor;
 use vortex_array::arrays::FilterVTable;
 use vortex_array::arrays::SliceReduceAdaptor;
-use vortex_array::compute::CastReduceAdaptor;
+use vortex_array::expr::CastReduceAdaptor;
 use vortex_array::optimizer::rules::ArrayParentReduceRule;
 use vortex_array::optimizer::rules::ParentRuleSet;
 use vortex_error::VortexResult;

encodings/fastlanes/src/rle/compute/cast.rs

@@ -4,7 +4,7 @@
 use vortex_array::Array;
 use vortex_array::ArrayRef;
 use vortex_array::builtins::ArrayBuiltins;
-use vortex_array::compute::CastReduce;
+use vortex_array::expr::CastReduce;
 use vortex_dtype::DType;
 use vortex_error::VortexResult;