Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 16 additions & 0 deletions encodings/alp/public-api.lock
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,10 @@ impl vortex_array::array::IntoArray for vortex_alp::ALPArray

pub fn vortex_alp::ALPArray::into_array(self) -> vortex_array::array::ArrayRef

impl vortex_array::stats::array::HasArrayStats for vortex_alp::ALPArray

pub fn vortex_alp::ALPArray::array_stats(&self) -> &vortex_array::stats::array::ArrayStats

pub struct vortex_alp::ALPMetadata

impl core::clone::Clone for vortex_alp::ALPMetadata
Expand Down Expand Up @@ -120,6 +124,10 @@ impl vortex_array::array::IntoArray for vortex_alp::ALPRDArray

pub fn vortex_alp::ALPRDArray::into_array(self) -> vortex_array::array::ArrayRef

impl vortex_array::stats::array::HasArrayStats for vortex_alp::ALPRDArray

pub fn vortex_alp::ALPRDArray::array_stats(&self) -> &vortex_array::stats::array::ArrayStats

pub struct vortex_alp::ALPRDMetadata

impl vortex_alp::ALPRDMetadata
Expand Down Expand Up @@ -152,6 +160,10 @@ impl vortex_alp::ALPRDVTable

pub const vortex_alp::ALPRDVTable::ID: vortex_array::vtable::dyn_::ArrayId

impl core::clone::Clone for vortex_alp::ALPRDVTable

pub fn vortex_alp::ALPRDVTable::clone(&self) -> vortex_alp::ALPRDVTable

impl core::fmt::Debug for vortex_alp::ALPRDVTable

pub fn vortex_alp::ALPRDVTable::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
Expand Down Expand Up @@ -240,6 +252,10 @@ impl vortex_alp::ALPVTable

pub const vortex_alp::ALPVTable::ID: vortex_array::vtable::dyn_::ArrayId

impl core::clone::Clone for vortex_alp::ALPVTable

pub fn vortex_alp::ALPVTable::clone(&self) -> vortex_alp::ALPVTable

impl core::fmt::Debug for vortex_alp::ALPVTable

pub fn vortex_alp::ALPVTable::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
Expand Down
9 changes: 8 additions & 1 deletion encodings/alp/src/alp/array.rs
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@ use vortex_array::patches::Patches;
use vortex_array::patches::PatchesMetadata;
use vortex_array::serde::ArrayChildren;
use vortex_array::stats::ArrayStats;
use vortex_array::stats::HasArrayStats;
use vortex_array::stats::StatsSetRef;
use vortex_array::vtable;
use vortex_array::vtable::ArrayId;
Expand Down Expand Up @@ -266,7 +267,13 @@ pub struct ALPArray {
stats_set: ArrayStats,
}

#[derive(Debug)]
impl HasArrayStats for ALPArray {
fn array_stats(&self) -> &ArrayStats {
&self.stats_set
}
}

#[derive(Clone, Debug)]
pub struct ALPVTable;

impl ALPVTable {
Expand Down
9 changes: 8 additions & 1 deletion encodings/alp/src/alp_rd/array.rs
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ use vortex_array::patches::Patches;
use vortex_array::patches::PatchesMetadata;
use vortex_array::serde::ArrayChildren;
use vortex_array::stats::ArrayStats;
use vortex_array::stats::HasArrayStats;
use vortex_array::stats::StatsSetRef;
use vortex_array::validity::Validity;
use vortex_array::vtable;
Expand Down Expand Up @@ -366,7 +367,13 @@ pub struct ALPRDArray {
stats_set: ArrayStats,
}

#[derive(Debug)]
impl HasArrayStats for ALPRDArray {
fn array_stats(&self) -> &ArrayStats {
&self.stats_set
}
}

#[derive(Clone, Debug)]
pub struct ALPRDVTable;

impl ALPRDVTable {
Expand Down
8 changes: 8 additions & 0 deletions encodings/bytebool/public-api.lock
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,10 @@ impl vortex_array::array::IntoArray for vortex_bytebool::ByteBoolArray

pub fn vortex_bytebool::ByteBoolArray::into_array(self) -> vortex_array::array::ArrayRef

impl vortex_array::stats::array::HasArrayStats for vortex_bytebool::ByteBoolArray

pub fn vortex_bytebool::ByteBoolArray::array_stats(&self) -> &vortex_array::stats::array::ArrayStats

impl vortex_array::vtable::validity::ValidityHelper for vortex_bytebool::ByteBoolArray

pub fn vortex_bytebool::ByteBoolArray::validity(&self) -> &vortex_array::validity::Validity
Expand All @@ -60,6 +64,10 @@ impl vortex_bytebool::ByteBoolVTable

pub const vortex_bytebool::ByteBoolVTable::ID: vortex_array::vtable::dyn_::ArrayId

impl core::clone::Clone for vortex_bytebool::ByteBoolVTable

pub fn vortex_bytebool::ByteBoolVTable::clone(&self) -> vortex_bytebool::ByteBoolVTable

impl core::fmt::Debug for vortex_bytebool::ByteBoolVTable

pub fn vortex_bytebool::ByteBoolVTable::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
Expand Down
9 changes: 8 additions & 1 deletion encodings/bytebool/src/array.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ use vortex_array::dtype::DType;
use vortex_array::scalar::Scalar;
use vortex_array::serde::ArrayChildren;
use vortex_array::stats::ArrayStats;
use vortex_array::stats::HasArrayStats;
use vortex_array::stats::StatsSetRef;
use vortex_array::validity::Validity;
use vortex_array::vtable;
Expand Down Expand Up @@ -206,7 +207,13 @@ pub struct ByteBoolArray {
stats_set: ArrayStats,
}

#[derive(Debug)]
impl HasArrayStats for ByteBoolArray {
fn array_stats(&self) -> &ArrayStats {
&self.stats_set
}
}

#[derive(Clone, Debug)]
pub struct ByteBoolVTable;

impl ByteBoolVTable {
Expand Down
8 changes: 8 additions & 0 deletions encodings/datetime-parts/public-api.lock
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,10 @@ impl vortex_array::array::IntoArray for vortex_datetime_parts::DateTimePartsArra

pub fn vortex_datetime_parts::DateTimePartsArray::into_array(self) -> vortex_array::array::ArrayRef

impl vortex_array::stats::array::HasArrayStats for vortex_datetime_parts::DateTimePartsArray

pub fn vortex_datetime_parts::DateTimePartsArray::array_stats(&self) -> &vortex_array::stats::array::ArrayStats

pub struct vortex_datetime_parts::DateTimePartsArrayParts

pub vortex_datetime_parts::DateTimePartsArrayParts::days: vortex_array::array::ArrayRef
Expand Down Expand Up @@ -122,6 +126,10 @@ impl vortex_datetime_parts::DateTimePartsVTable

pub const vortex_datetime_parts::DateTimePartsVTable::ID: vortex_array::vtable::dyn_::ArrayId

impl core::clone::Clone for vortex_datetime_parts::DateTimePartsVTable

pub fn vortex_datetime_parts::DateTimePartsVTable::clone(&self) -> vortex_datetime_parts::DateTimePartsVTable

impl core::fmt::Debug for vortex_datetime_parts::DateTimePartsVTable

pub fn vortex_datetime_parts::DateTimePartsVTable::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
Expand Down
9 changes: 8 additions & 1 deletion encodings/datetime-parts/src/array.rs
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@ use vortex_array::dtype::Nullability;
use vortex_array::dtype::PType;
use vortex_array::serde::ArrayChildren;
use vortex_array::stats::ArrayStats;
use vortex_array::stats::HasArrayStats;
use vortex_array::stats::StatsSetRef;
use vortex_array::vtable;
use vortex_array::vtable::ArrayId;
Expand Down Expand Up @@ -252,6 +253,12 @@ pub struct DateTimePartsArray {
stats_set: ArrayStats,
}

impl HasArrayStats for DateTimePartsArray {
fn array_stats(&self) -> &ArrayStats {
&self.stats_set
}
}

#[derive(Clone, Debug)]
pub struct DateTimePartsArrayParts {
pub dtype: DType,
Expand All @@ -260,7 +267,7 @@ pub struct DateTimePartsArrayParts {
pub subseconds: ArrayRef,
}

#[derive(Debug)]
#[derive(Clone, Debug)]
pub struct DateTimePartsVTable;

impl DateTimePartsVTable {
Expand Down
8 changes: 8 additions & 0 deletions encodings/decimal-byte-parts/public-api.lock
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,10 @@ impl vortex_array::array::IntoArray for vortex_decimal_byte_parts::DecimalBytePa

pub fn vortex_decimal_byte_parts::DecimalBytePartsArray::into_array(self) -> vortex_array::array::ArrayRef

impl vortex_array::stats::array::HasArrayStats for vortex_decimal_byte_parts::DecimalBytePartsArray

pub fn vortex_decimal_byte_parts::DecimalBytePartsArray::array_stats(&self) -> &vortex_array::stats::array::ArrayStats

pub struct vortex_decimal_byte_parts::DecimalBytePartsArrayParts

pub vortex_decimal_byte_parts::DecimalBytePartsArrayParts::dtype: vortex_array::dtype::DType
Expand All @@ -52,6 +56,10 @@ impl vortex_decimal_byte_parts::DecimalBytePartsVTable

pub const vortex_decimal_byte_parts::DecimalBytePartsVTable::ID: vortex_array::vtable::dyn_::ArrayId

impl core::clone::Clone for vortex_decimal_byte_parts::DecimalBytePartsVTable

pub fn vortex_decimal_byte_parts::DecimalBytePartsVTable::clone(&self) -> vortex_decimal_byte_parts::DecimalBytePartsVTable

impl core::fmt::Debug for vortex_decimal_byte_parts::DecimalBytePartsVTable

pub fn vortex_decimal_byte_parts::DecimalBytePartsVTable::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
Expand Down
9 changes: 8 additions & 1 deletion encodings/decimal-byte-parts/src/decimal_byte_parts/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ use vortex_array::scalar::Scalar;
use vortex_array::scalar::ScalarValue;
use vortex_array::serde::ArrayChildren;
use vortex_array::stats::ArrayStats;
use vortex_array::stats::HasArrayStats;
use vortex_array::stats::StatsSetRef;
use vortex_array::vtable;
use vortex_array::vtable::ArrayId;
Expand Down Expand Up @@ -220,6 +221,12 @@ pub struct DecimalBytePartsArray {
stats_set: ArrayStats,
}

impl HasArrayStats for DecimalBytePartsArray {
fn array_stats(&self) -> &ArrayStats {
&self.stats_set
}
}

pub struct DecimalBytePartsArrayParts {
pub msp: ArrayRef,
pub dtype: DType,
Expand Down Expand Up @@ -269,7 +276,7 @@ impl DecimalBytePartsArray {
}
}

#[derive(Debug)]
#[derive(Clone, Debug)]
pub struct DecimalBytePartsVTable;

impl DecimalBytePartsVTable {
Expand Down
32 changes: 32 additions & 0 deletions encodings/fastlanes/public-api.lock
Original file line number Diff line number Diff line change
Expand Up @@ -164,6 +164,10 @@ impl vortex_array::array::IntoArray for vortex_fastlanes::BitPackedArray

pub fn vortex_fastlanes::BitPackedArray::into_array(self) -> vortex_array::array::ArrayRef

impl vortex_array::stats::array::HasArrayStats for vortex_fastlanes::BitPackedArray

pub fn vortex_fastlanes::BitPackedArray::array_stats(&self) -> &vortex_array::stats::array::ArrayStats

impl vortex_array::vtable::validity::ValidityHelper for vortex_fastlanes::BitPackedArray

pub fn vortex_fastlanes::BitPackedArray::validity(&self) -> &vortex_array::validity::Validity
Expand All @@ -188,6 +192,10 @@ impl vortex_fastlanes::BitPackedVTable

pub const vortex_fastlanes::BitPackedVTable::ID: vortex_array::vtable::dyn_::ArrayId

impl core::clone::Clone for vortex_fastlanes::BitPackedVTable

pub fn vortex_fastlanes::BitPackedVTable::clone(&self) -> vortex_fastlanes::BitPackedVTable

impl core::fmt::Debug for vortex_fastlanes::BitPackedVTable

pub fn vortex_fastlanes::BitPackedVTable::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
Expand Down Expand Up @@ -322,6 +330,10 @@ impl vortex_array::array::IntoArray for vortex_fastlanes::DeltaArray

pub fn vortex_fastlanes::DeltaArray::into_array(self) -> vortex_array::array::ArrayRef

impl vortex_array::stats::array::HasArrayStats for vortex_fastlanes::DeltaArray

pub fn vortex_fastlanes::DeltaArray::array_stats(&self) -> &vortex_array::stats::array::ArrayStats

impl vortex_array::vtable::validity::ValidityChildSliceHelper for vortex_fastlanes::DeltaArray

pub fn vortex_fastlanes::DeltaArray::unsliced_child_and_slice(&self) -> (&vortex_array::array::ArrayRef, usize, usize)
Expand All @@ -332,6 +344,10 @@ impl vortex_fastlanes::DeltaVTable

pub const vortex_fastlanes::DeltaVTable::ID: vortex_array::vtable::dyn_::ArrayId

impl core::clone::Clone for vortex_fastlanes::DeltaVTable

pub fn vortex_fastlanes::DeltaVTable::clone(&self) -> vortex_fastlanes::DeltaVTable

impl core::fmt::Debug for vortex_fastlanes::DeltaVTable

pub fn vortex_fastlanes::DeltaVTable::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
Expand Down Expand Up @@ -442,12 +458,20 @@ impl vortex_array::array::IntoArray for vortex_fastlanes::FoRArray

pub fn vortex_fastlanes::FoRArray::into_array(self) -> vortex_array::array::ArrayRef

impl vortex_array::stats::array::HasArrayStats for vortex_fastlanes::FoRArray

pub fn vortex_fastlanes::FoRArray::array_stats(&self) -> &vortex_array::stats::array::ArrayStats

pub struct vortex_fastlanes::FoRVTable

impl vortex_fastlanes::FoRVTable

pub const vortex_fastlanes::FoRVTable::ID: vortex_array::vtable::dyn_::ArrayId

impl core::clone::Clone for vortex_fastlanes::FoRVTable

pub fn vortex_fastlanes::FoRVTable::clone(&self) -> vortex_fastlanes::FoRVTable

impl core::fmt::Debug for vortex_fastlanes::FoRVTable

pub fn vortex_fastlanes::FoRVTable::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
Expand Down Expand Up @@ -596,6 +620,10 @@ impl vortex_array::array::IntoArray for vortex_fastlanes::RLEArray

pub fn vortex_fastlanes::RLEArray::into_array(self) -> vortex_array::array::ArrayRef

impl vortex_array::stats::array::HasArrayStats for vortex_fastlanes::RLEArray

pub fn vortex_fastlanes::RLEArray::array_stats(&self) -> &vortex_array::stats::array::ArrayStats

impl vortex_array::vtable::validity::ValidityChildSliceHelper for vortex_fastlanes::RLEArray

pub fn vortex_fastlanes::RLEArray::unsliced_child_and_slice(&self) -> (&vortex_array::array::ArrayRef, usize, usize)
Expand All @@ -606,6 +634,10 @@ impl vortex_fastlanes::RLEVTable

pub const vortex_fastlanes::RLEVTable::ID: vortex_array::vtable::dyn_::ArrayId

impl core::clone::Clone for vortex_fastlanes::RLEVTable

pub fn vortex_fastlanes::RLEVTable::clone(&self) -> vortex_fastlanes::RLEVTable

impl core::fmt::Debug for vortex_fastlanes::RLEVTable

pub fn vortex_fastlanes::RLEVTable::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
Expand Down
7 changes: 7 additions & 0 deletions encodings/fastlanes/src/bitpacking/array/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ use vortex_array::dtype::NativePType;
use vortex_array::dtype::PType;
use vortex_array::patches::Patches;
use vortex_array::stats::ArrayStats;
use vortex_array::stats::HasArrayStats;
use vortex_array::validity::Validity;
use vortex_error::VortexResult;
use vortex_error::vortex_bail;
Expand Down Expand Up @@ -46,6 +47,12 @@ pub struct BitPackedArray {
pub(super) stats_set: ArrayStats,
}

impl HasArrayStats for BitPackedArray {
fn array_stats(&self) -> &ArrayStats {
&self.stats_set
}
}

impl BitPackedArray {
/// Create a new bitpacked array using a buffer of packed data.
///
Expand Down
2 changes: 1 addition & 1 deletion encodings/fastlanes/src/bitpacking/vtable/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -367,7 +367,7 @@ impl VTable for BitPackedVTable {
}
}

#[derive(Debug)]
#[derive(Clone, Debug)]
pub struct BitPackedVTable;

impl BitPackedVTable {
Expand Down
7 changes: 7 additions & 0 deletions encodings/fastlanes/src/delta/array/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ use vortex_array::dtype::NativePType;
use vortex_array::dtype::PType;
use vortex_array::match_each_unsigned_integer_ptype;
use vortex_array::stats::ArrayStats;
use vortex_array::stats::HasArrayStats;
use vortex_array::validity::Validity;
use vortex_buffer::Buffer;
use vortex_error::VortexExpect as _;
Expand Down Expand Up @@ -63,6 +64,12 @@ pub struct DeltaArray {
pub(super) stats_set: ArrayStats,
}

impl HasArrayStats for DeltaArray {
fn array_stats(&self) -> &ArrayStats {
&self.stats_set
}
}

impl DeltaArray {
// TODO(ngates): remove constructing from vec
pub fn try_from_vec<T: NativePType>(vec: Vec<T>) -> VortexResult<Self> {
Expand Down
2 changes: 1 addition & 1 deletion encodings/fastlanes/src/delta/vtable/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -194,7 +194,7 @@ impl VTable for DeltaVTable {
}
}

#[derive(Debug)]
#[derive(Clone, Debug)]
pub struct DeltaVTable;

impl DeltaVTable {
Expand Down
Loading
Loading