Skip to content

Commit 78f48c6

Browse files
authored
feat: teach PrimitiveArrayTrait iterate_primitive_array! and RowMask from_index_array (#1241)
This touches a dumb number of files and regardless of how the `with_indices` implementation shakes out, I think we'll need it.
1 parent 26d0a72 commit 78f48c6

File tree

63 files changed

+158
-64
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

63 files changed

+158
-64
lines changed

encodings/alp/src/alp/array.rs

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -105,13 +105,6 @@ impl ALPArray {
105105
})
106106
}
107107

108-
#[inline]
109-
pub fn ptype(&self) -> PType {
110-
self.dtype()
111-
.try_into()
112-
.vortex_expect("Failed to convert DType to PType")
113-
}
114-
115108
#[inline]
116109
fn encoded_dtype(&self) -> DType {
117110
match self.dtype() {

encodings/alp/src/alp/compress.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
use vortex_array::array::{PrimitiveArray, Sparse, SparseArray};
22
use vortex_array::validity::Validity;
3+
use vortex_array::variants::PrimitiveArrayTrait;
34
use vortex_array::{Array, ArrayDType, ArrayDef, IntoArray, IntoArrayVariant};
45
use vortex_dtype::{NativePType, PType};
56
use vortex_error::{vortex_bail, VortexExpect as _, VortexResult};

encodings/alp/src/alp/compute.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ use vortex_array::compute::{
55
};
66
use vortex_array::stats::{ArrayStatistics, Stat};
77
use vortex_array::validity::Validity;
8+
use vortex_array::variants::PrimitiveArrayTrait;
89
use vortex_array::{Array, ArrayDType, IntoArray};
910
use vortex_error::{VortexExpect, VortexResult};
1011
use vortex_scalar::{PValue, Scalar};

encodings/alp/src/alp_rd/mod.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
pub use array::*;
22
use vortex_array::validity::Validity;
3+
use vortex_array::variants::PrimitiveArrayTrait;
34

45
mod array;
56
mod compute;

encodings/bytebool/src/compute.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ use num_traits::AsPrimitive;
22
use vortex_array::compute::unary::{FillForwardFn, ScalarAtFn};
33
use vortex_array::compute::{ArrayCompute, SliceFn, TakeFn};
44
use vortex_array::validity::{ArrayValidity, Validity};
5+
use vortex_array::variants::PrimitiveArrayTrait;
56
use vortex_array::{Array, ArrayDType, IntoArray};
67
use vortex_dtype::{match_each_integer_ptype, Nullability};
78
use vortex_error::{vortex_err, VortexResult};

encodings/dict/src/array.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ use vortex_array::compute::unary::scalar_at;
99
use vortex_array::encoding::ids;
1010
use vortex_array::stats::StatsSet;
1111
use vortex_array::validity::{ArrayValidity, LogicalValidity};
12+
use vortex_array::variants::PrimitiveArrayTrait;
1213
use vortex_array::{
1314
impl_encoding, Array, ArrayDType, ArrayTrait, Canonical, IntoArray, IntoArrayVariant,
1415
IntoCanonical,

encodings/dict/src/compress.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ use vortex_array::array::{
99
ConstantArray, PrimitiveArray, SparseArray, VarBinArray, VarBinViewArray,
1010
};
1111
use vortex_array::validity::Validity;
12+
use vortex_array::variants::PrimitiveArrayTrait;
1213
use vortex_array::{ArrayDType, IntoArray, IntoCanonical};
1314
use vortex_dtype::{match_each_native_ptype, DType, NativePType, ToBytes};
1415
use vortex_error::{VortexExpect as _, VortexUnwrap};

encodings/fastlanes/src/bitpacking/compress.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ use fastlanes::BitPacking;
33
use vortex_array::array::{PrimitiveArray, Sparse, SparseArray};
44
use vortex_array::stats::ArrayStatistics;
55
use vortex_array::validity::{ArrayValidity, Validity};
6+
use vortex_array::variants::PrimitiveArrayTrait;
67
use vortex_array::{Array, ArrayDType, ArrayDef, IntoArray, IntoArrayVariant};
78
use vortex_buffer::Buffer;
89
use vortex_dtype::{

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ use vortex_array::compute::{
1010
search_sorted_u64, IndexOrd, Len, SearchResult, SearchSorted, SearchSortedFn, SearchSortedSide,
1111
};
1212
use vortex_array::validity::Validity;
13+
use vortex_array::variants::PrimitiveArrayTrait;
1314
use vortex_array::ArrayDType;
1415
use vortex_dtype::{match_each_unsigned_integer_ptype, NativePType};
1516
use vortex_error::{VortexError, VortexExpect as _, VortexResult};

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ use std::cmp::max;
22

33
use vortex_array::array::SparseArray;
44
use vortex_array::compute::{slice, SliceFn};
5+
use vortex_array::variants::PrimitiveArrayTrait;
56
use vortex_array::{Array, IntoArray};
67
use vortex_error::{VortexExpect, VortexResult};
78

0 commit comments

Comments
 (0)