ALP pipeline kernel

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

Author: gatesn

encodings/alp/src/alp/operator.rs

@@ -1,17 +1,19 @@
 // SPDX-License-Identifier: Apache-2.0
 // SPDX-FileCopyrightText: Copyright the Vortex contributors
 
-use crate::{match_each_alp_float_ptype, ALPArray, ALPFloat, ALPVTable, Exponents};
 use std::marker::PhantomData;
+
 use vortex_array::pipeline::bit_view::BitView;
 use vortex_array::pipeline::{
-    BindContext, Kernel, KernelCtx, PipelineInputs, PipelinedNode, VectorId, N,
+    BindContext, Kernel, KernelCtx, N, PipelineInputs, PipelinedNode, VectorId,
 };
 use vortex_array::vtable::OperatorVTable;
 use vortex_dtype::PTypeDowncastExt;
-use vortex_error::{vortex_bail, VortexResult};
+use vortex_error::{VortexResult, vortex_bail};
 use vortex_vector::{VectorMut, VectorMutOps};
 
+use crate::{ALPArray, ALPFloat, ALPVTable, Exponents, match_each_alp_float_ptype};
+
 impl OperatorVTable<ALPVTable> for ALPVTable {
     fn pipeline_node(array: &ALPArray) -> Option<&dyn PipelinedNode> {
         Some(array)
@@ -37,7 +39,7 @@ impl PipelinedNode for ALPArray {
                     Ok(Box::new(UnpatchedALPKernel {
                         encoded_vector_id,
                         exponents: self.exponents(),
-                        _phantom: PhantomData::<A>::default(),
+                        _phantom: PhantomData::<A>,
                     }))
                 })
             }

vortex-array/src/pipeline/driver/allocation.rs

@@ -6,9 +6,9 @@
 use vortex_error::{VortexExpect, VortexResult};
 use vortex_vector::VectorMut;
 
-use crate::pipeline::driver::{Node, NodeId};
-use crate::pipeline::{VectorId, N};
 use crate::Array;
+use crate::pipeline::driver::{Node, NodeId};
+use crate::pipeline::{N, VectorId};
 
 #[derive(Debug)]
 pub struct VectorAllocation {

vortex-array/src/pipeline/driver/mod.rs

@@ -10,16 +10,16 @@ use std::hash::{BuildHasher, Hash, Hasher};
 
 use itertools::Itertools;
 use vortex_dtype::DType;
-use vortex_error::{vortex_bail, VortexResult};
+use vortex_error::{VortexResult, vortex_bail};
 use vortex_mask::Mask;
 use vortex_utils::aliases::hash_map::{HashMap, RandomState};
 use vortex_vector::{Vector, VectorMut, VectorMutOps};
 
 use crate::pipeline::bit_view::{BitView, BitViewExt};
-use crate::pipeline::driver::allocation::{allocate_vectors, OutputTarget};
+use crate::pipeline::driver::allocation::{OutputTarget, allocate_vectors};
 use crate::pipeline::driver::bind::bind_kernels;
 use crate::pipeline::driver::toposort::topological_sort;
-use crate::pipeline::{Kernel, KernelCtx, PipelineInputs, N};
+use crate::pipeline::{Kernel, KernelCtx, N, PipelineInputs};
 use crate::{Array, ArrayEq, ArrayHash, ArrayOperator, ArrayRef, ArrayVisitor, Precision};
 
 /// A pipeline driver takes a Vortex array and executes it into a canonical vector.

vortex-array/src/pipeline/mod.rs

@@ -4,7 +4,6 @@
 pub mod bit_view;
 pub mod driver;
 
-use std::ops::Deref;
 use vortex_error::{VortexExpect, VortexResult};
 use vortex_vector::{Vector, VectorMut};
 

vortex-vector/src/primitive/vector_mut.rs

@@ -9,7 +9,7 @@ use vortex_error::vortex_panic;
 use vortex_mask::MaskMut;
 
 use crate::primitive::{PVectorMut, PrimitiveVector};
-use crate::{match_each_pvector_mut, VectorMutOps};
+use crate::{VectorMutOps, match_each_pvector_mut};
 
 /// A mutable vector of primitive values.
 ///

vortex-vector/src/vector_mut.rs

@@ -18,7 +18,7 @@ use crate::listview::ListViewVectorMut;
 use crate::null::NullVectorMut;
 use crate::primitive::PrimitiveVectorMut;
 use crate::struct_::StructVectorMut;
-use crate::{match_each_vector_mut, match_vector_pair, Vector, VectorMutOps};
+use crate::{Vector, VectorMutOps, match_each_vector_mut, match_vector_pair};
 
 /// An enum over all kinds of mutable vectors, which represent fully decompressed (canonical) array
 /// data.
@@ -339,9 +339,9 @@ mod tests {
     use vortex_dtype::{DecimalDType, Nullability, PType};
 
     use super::*;
+    use crate::VectorOps;
     use crate::decimal::DecimalVectorMut;
     use crate::primitive::PVectorMut;
-    use crate::VectorOps;
 
     #[test]
     fn test_with_capacity() {