Skip to content

feat[array]: lazy numeric #6469

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
joseph-isaacs merged 4 commits into from
Feb 13, 2026
Merged

feat[array]: lazy numeric #6469

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
ad01988
feat[array]: lazy numeric
joseph-isaacs Feb 12, 2026
ef2641d
feat[array]: lazy numeric
joseph-isaacs Feb 13, 2026
e1f59b5
Merge remote-tracking branch 'origin/develop' into ji/lazy-numeric
joseph-isaacs Feb 13, 2026
84653c9
fix
joseph-isaacs Feb 13, 2026
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
2 changes: 0 additions & 2 deletions encodings/runend/public-api.lock
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -69,8 +69,6 @@ pub fn vortex_runend::RunEndVTable::is_sorted(&self, array: &vortex_runend::RunE
pub fn vortex_runend::RunEndVTable::is_strict_sorted(&self, array: &vortex_runend::RunEndArray) -> vortex_error::VortexResult<core::option::Option<bool>>
impl vortex_array::compute::min_max::MinMaxKernel for vortex_runend::RunEndVTable
pub fn vortex_runend::RunEndVTable::min_max(&self, array: &vortex_runend::RunEndArray) -> vortex_error::VortexResult<core::option::Option<vortex_array::compute::min_max::MinMaxResult>>
impl vortex_array::compute::numeric::NumericKernel for vortex_runend::RunEndVTable
pub fn vortex_runend::RunEndVTable::numeric(&self, array: &vortex_runend::RunEndArray, rhs: &dyn vortex_array::array::Array, op: vortex_scalar::typed_view::primitive::numeric_operator::NumericOperator) -> vortex_error::VortexResult<core::option::Option<vortex_array::array::ArrayRef>>
impl vortex_array::expr::exprs::fill_null::kernel::FillNullReduce for vortex_runend::RunEndVTable
pub fn vortex_runend::RunEndVTable::fill_null(array: &vortex_runend::RunEndArray, fill_value: &vortex_scalar::scalar::Scalar) -> vortex_error::VortexResult<core::option::Option<vortex_array::array::ArrayRef>>
impl vortex_array::vtable::VTable for vortex_runend::RunEndVTable
Expand Down
83 changes: 0 additions & 83 deletions encodings/runend/src/compute/binary_numeric.rs
View file
Open in desktop

This file was deleted.

1 change: 0 additions & 1 deletion encodings/runend/src/compute/mod.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
// SPDX-License-Identifier: Apache-2.0
// SPDX-FileCopyrightText: Copyright the Vortex contributors

mod binary_numeric;
mod cast;
mod compare;
mod fill_null;
Expand Down
2 changes: 0 additions & 2 deletions encodings/sparse/public-api.lock
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -43,8 +43,6 @@ impl vortex_array::arrays::slice::SliceKernel for vortex_sparse::SparseVTable
pub fn vortex_sparse::SparseVTable::slice(array: &vortex_sparse::SparseArray, range: core::ops::range::Range<usize>, _ctx: &mut vortex_array::executor::ExecutionCtx) -> vortex_error::VortexResult<core::option::Option<vortex_array::array::ArrayRef>>
impl vortex_array::compute::cast::CastReduce for vortex_sparse::SparseVTable
pub fn vortex_sparse::SparseVTable::cast(array: &vortex_sparse::SparseArray, dtype: &vortex_dtype::dtype::DType) -> vortex_error::VortexResult<core::option::Option<vortex_array::array::ArrayRef>>
impl vortex_array::compute::numeric::NumericKernel for vortex_sparse::SparseVTable
pub fn vortex_sparse::SparseVTable::numeric(&self, array: &vortex_sparse::SparseArray, rhs: &dyn vortex_array::array::Array, op: vortex_scalar::typed_view::primitive::numeric_operator::NumericOperator) -> vortex_error::VortexResult<core::option::Option<vortex_array::array::ArrayRef>>
impl vortex_array::expr::exprs::not::kernel::NotReduce for vortex_sparse::SparseVTable
pub fn vortex_sparse::SparseVTable::invert(array: &vortex_sparse::SparseArray) -> vortex_error::VortexResult<core::option::Option<vortex_array::array::ArrayRef>>
impl vortex_array::vtable::VTable for vortex_sparse::SparseVTable
Expand Down
47 changes: 0 additions & 47 deletions encodings/sparse/src/compute/binary_numeric.rs
View file
Open in desktop

This file was deleted.

1 change: 0 additions & 1 deletion encodings/sparse/src/compute/mod.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
// SPDX-License-Identifier: Apache-2.0
// SPDX-FileCopyrightText: Copyright the Vortex contributors

mod binary_numeric;
mod cast;
mod filter;
mod take;
Expand Down
23 changes: 0 additions & 23 deletions vortex-array/public-api.lock
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -61,8 +61,6 @@ impl vortex_array::compute::LikeKernel for vortex_array::arrays::DictVTable
pub fn vortex_array::arrays::DictVTable::like(&self, array: &vortex_array::arrays::DictArray, pattern: &dyn vortex_array::Array, options: vortex_array::compute::LikeOptions) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
impl vortex_array::compute::MinMaxKernel for vortex_array::arrays::DictVTable
pub fn vortex_array::arrays::DictVTable::min_max(&self, array: &vortex_array::arrays::DictArray) -> vortex_error::VortexResult<core::option::Option<vortex_array::compute::MinMaxResult>>
impl vortex_array::compute::NumericKernel for vortex_array::arrays::DictVTable
pub fn vortex_array::arrays::DictVTable::numeric(&self, lhs: &vortex_array::arrays::DictArray, rhs: &dyn vortex_array::Array, op: vortex_scalar::typed_view::primitive::numeric_operator::NumericOperator) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
impl vortex_array::expr::FillNullKernel for vortex_array::arrays::DictVTable
pub fn vortex_array::arrays::DictVTable::fill_null(array: &vortex_array::arrays::DictArray, fill_value: &vortex_scalar::scalar::Scalar, _ctx: &mut vortex_array::ExecutionCtx) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
impl vortex_array::vtable::BaseArrayVTable<vortex_array::arrays::DictVTable> for vortex_array::arrays::DictVTable
Expand Down Expand Up @@ -354,8 +352,6 @@ impl vortex_array::compute::MaskKernel for vortex_array::arrays::ConstantVTable
pub fn vortex_array::arrays::ConstantVTable::mask(&self, array: &vortex_array::arrays::ConstantArray, mask: &vortex_mask::Mask) -> vortex_error::VortexResult<vortex_array::ArrayRef>
impl vortex_array::compute::MinMaxKernel for vortex_array::arrays::ConstantVTable
pub fn vortex_array::arrays::ConstantVTable::min_max(&self, array: &vortex_array::arrays::ConstantArray) -> vortex_error::VortexResult<core::option::Option<vortex_array::compute::MinMaxResult>>
impl vortex_array::compute::NumericKernel for vortex_array::arrays::ConstantVTable
pub fn vortex_array::arrays::ConstantVTable::numeric(&self, array: &vortex_array::arrays::ConstantArray, rhs: &dyn vortex_array::Array, op: vortex_scalar::typed_view::primitive::numeric_operator::NumericOperator) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
impl vortex_array::compute::SumKernel for vortex_array::arrays::ConstantVTable
pub fn vortex_array::arrays::ConstantVTable::sum(&self, array: &vortex_array::arrays::ConstantArray, accumulator: &vortex_scalar::scalar::Scalar) -> vortex_error::VortexResult<vortex_scalar::scalar::Scalar>
impl vortex_array::expr::FillNullReduce for vortex_array::arrays::ConstantVTable
Expand Down Expand Up @@ -573,8 +569,6 @@ impl vortex_array::compute::LikeKernel for vortex_array::arrays::DictVTable
pub fn vortex_array::arrays::DictVTable::like(&self, array: &vortex_array::arrays::DictArray, pattern: &dyn vortex_array::Array, options: vortex_array::compute::LikeOptions) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
impl vortex_array::compute::MinMaxKernel for vortex_array::arrays::DictVTable
pub fn vortex_array::arrays::DictVTable::min_max(&self, array: &vortex_array::arrays::DictArray) -> vortex_error::VortexResult<core::option::Option<vortex_array::compute::MinMaxResult>>
impl vortex_array::compute::NumericKernel for vortex_array::arrays::DictVTable
pub fn vortex_array::arrays::DictVTable::numeric(&self, lhs: &vortex_array::arrays::DictArray, rhs: &dyn vortex_array::Array, op: vortex_scalar::typed_view::primitive::numeric_operator::NumericOperator) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
impl vortex_array::expr::FillNullKernel for vortex_array::arrays::DictVTable
pub fn vortex_array::arrays::DictVTable::fill_null(array: &vortex_array::arrays::DictArray, fill_value: &vortex_scalar::scalar::Scalar, _ctx: &mut vortex_array::ExecutionCtx) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
impl vortex_array::vtable::BaseArrayVTable<vortex_array::arrays::DictVTable> for vortex_array::arrays::DictVTable
Expand Down Expand Up @@ -3031,15 +3025,6 @@ pub fn vortex_array::expr::NotReduceAdaptor<V>::fmt(&self, f: &mut core::fmt::Fo
impl<V> vortex_array::optimizer::rules::ArrayParentReduceRule<V> for vortex_array::expr::NotReduceAdaptor<V> where V: vortex_array::expr::NotReduce
pub type vortex_array::expr::NotReduceAdaptor<V>::Parent = vortex_array::arrays::ExactScalarFn<vortex_array::expr::Not>
pub fn vortex_array::expr::NotReduceAdaptor<V>::reduce_parent(&self, array: &<V as vortex_array::vtable::VTable>::Array, _parent: vortex_array::arrays::ScalarFnArrayView<'_, vortex_array::expr::Not>, _child_idx: usize) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
pub struct vortex_array::compute::NumericKernelAdapter<V: vortex_array::vtable::VTable>(pub V)
impl<V: vortex_array::vtable::VTable + vortex_array::compute::NumericKernel> vortex_array::compute::NumericKernelAdapter<V>
pub const fn vortex_array::compute::NumericKernelAdapter<V>::lift(&'static self) -> vortex_array::compute::NumericKernelRef
impl<V: core::fmt::Debug + vortex_array::vtable::VTable> core::fmt::Debug for vortex_array::compute::NumericKernelAdapter<V>
pub fn vortex_array::compute::NumericKernelAdapter<V>::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<V: vortex_array::vtable::VTable + vortex_array::compute::NumericKernel> vortex_array::compute::Kernel for vortex_array::compute::NumericKernelAdapter<V>
pub fn vortex_array::compute::NumericKernelAdapter<V>::invoke(&self, args: &vortex_array::compute::InvocationArgs<'_>) -> vortex_error::VortexResult<core::option::Option<vortex_array::compute::Output>>
pub struct vortex_array::compute::NumericKernelRef(_)
impl inventory::Collect for vortex_array::compute::NumericKernelRef
pub struct vortex_array::compute::SumArgs<'a>
pub vortex_array::compute::SumArgs::accumulator: &'a vortex_scalar::scalar::Scalar
pub vortex_array::compute::SumArgs::array: &'a dyn vortex_array::Array
Expand Down Expand Up @@ -3239,8 +3224,6 @@ impl<V: vortex_array::vtable::VTable + vortex_array::compute::MinMaxKernel> vort
pub fn vortex_array::compute::MinMaxKernelAdapter<V>::invoke(&self, args: &vortex_array::compute::InvocationArgs<'_>) -> vortex_error::VortexResult<core::option::Option<vortex_array::compute::Output>>
impl<V: vortex_array::vtable::VTable + vortex_array::compute::NaNCountKernel> vortex_array::compute::Kernel for vortex_array::compute::NaNCountKernelAdapter<V>
pub fn vortex_array::compute::NaNCountKernelAdapter<V>::invoke(&self, args: &vortex_array::compute::InvocationArgs<'_>) -> vortex_error::VortexResult<core::option::Option<vortex_array::compute::Output>>
impl<V: vortex_array::vtable::VTable + vortex_array::compute::NumericKernel> vortex_array::compute::Kernel for vortex_array::compute::NumericKernelAdapter<V>
pub fn vortex_array::compute::NumericKernelAdapter<V>::invoke(&self, args: &vortex_array::compute::InvocationArgs<'_>) -> vortex_error::VortexResult<core::option::Option<vortex_array::compute::Output>>
impl<V: vortex_array::vtable::VTable + vortex_array::compute::SumKernel> vortex_array::compute::Kernel for vortex_array::compute::SumKernelAdapter<V>
pub fn vortex_array::compute::SumKernelAdapter<V>::invoke(&self, args: &vortex_array::compute::InvocationArgs<'_>) -> vortex_error::VortexResult<core::option::Option<vortex_array::compute::Output>>
impl<V: vortex_array::vtable::VTable + vortex_array::compute::ZipKernel> vortex_array::compute::Kernel for vortex_array::compute::ZipKernelAdapter<V>
Expand Down Expand Up @@ -3319,12 +3302,6 @@ pub trait vortex_array::compute::NotReduce: vortex_array::vtable::VTable
pub fn vortex_array::compute::NotReduce::invert(array: &Self::Array) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
impl vortex_array::expr::NotReduce for vortex_array::arrays::ConstantVTable
pub fn vortex_array::arrays::ConstantVTable::invert(array: &vortex_array::arrays::ConstantArray) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
pub trait vortex_array::compute::NumericKernel: vortex_array::vtable::VTable
pub fn vortex_array::compute::NumericKernel::numeric(&self, array: &Self::Array, other: &dyn vortex_array::Array, op: vortex_scalar::typed_view::primitive::numeric_operator::NumericOperator) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
impl vortex_array::compute::NumericKernel for vortex_array::arrays::ConstantVTable
pub fn vortex_array::arrays::ConstantVTable::numeric(&self, array: &vortex_array::arrays::ConstantArray, rhs: &dyn vortex_array::Array, op: vortex_scalar::typed_view::primitive::numeric_operator::NumericOperator) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
impl vortex_array::compute::NumericKernel for vortex_array::arrays::DictVTable
pub fn vortex_array::arrays::DictVTable::numeric(&self, lhs: &vortex_array::arrays::DictArray, rhs: &dyn vortex_array::Array, op: vortex_scalar::typed_view::primitive::numeric_operator::NumericOperator) -> vortex_error::VortexResult<core::option::Option<vortex_array::ArrayRef>>
pub trait vortex_array::compute::Options: 'static
pub fn vortex_array::compute::Options::as_any(&self) -> &dyn core::any::Any
impl vortex_array::compute::Options for ()
Expand Down
42 changes: 0 additions & 42 deletions vortex-array/src/arrays/constant/compute/binary_numeric.rs
View file
Open in desktop

This file was deleted.

1 change: 0 additions & 1 deletion vortex-array/src/arrays/constant/compute/mod.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
// SPDX-License-Identifier: Apache-2.0
// SPDX-FileCopyrightText: Copyright the Vortex contributors

mod binary_numeric;
mod cast;
mod compare;
mod fill_null;
Expand Down
Loading
Loading