Skip to content
Merged
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
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/all_nan/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@

use vortex_error::VortexResult;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand Down Expand Up @@ -34,7 +35,8 @@ impl AggregateFnVTable for AllNan {
type Partial = bool;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.all_nan")
static ID: CachedId = CachedId::new("vortex.all_nan");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/all_non_distinct/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ use std::sync::LazyLock;
use vortex_error::VortexResult;
use vortex_error::vortex_bail;
use vortex_error::vortex_err;
use vortex_session::registry::CachedId;

use self::bool::check_bool_identical;
use self::decimal::check_decimal_identical;
Expand Down Expand Up @@ -121,7 +122,8 @@ impl AggregateFnVTable for AllNonDistinct {
type Partial = AllNonDistinctPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.all_non_distinct")
static ID: CachedId = CachedId::new("vortex.all_non_distinct");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/all_non_nan/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@

use vortex_error::VortexResult;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand Down Expand Up @@ -34,7 +35,8 @@ impl AggregateFnVTable for AllNonNan {
type Partial = bool;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.all_non_nan")
static ID: CachedId = CachedId::new("vortex.all_non_nan");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/all_non_null/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@

use vortex_error::VortexResult;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand All @@ -26,7 +27,8 @@ impl AggregateFnVTable for AllNonNull {
type Partial = bool;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.all_non_null")
static ID: CachedId = CachedId::new("vortex.all_non_null");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/all_null/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@

use vortex_error::VortexResult;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand All @@ -26,7 +27,8 @@ impl AggregateFnVTable for AllNull {
type Partial = bool;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.all_null")
static ID: CachedId = CachedId::new("vortex.all_null");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/bounded_max/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ use vortex_error::VortexResult;
use vortex_error::vortex_bail;
use vortex_error::vortex_ensure;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand Down Expand Up @@ -125,7 +126,8 @@ impl AggregateFnVTable for BoundedMax {
type Partial = BoundedMaxPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.bounded_max")
static ID: CachedId = CachedId::new("vortex.bounded_max");
*ID
}

fn serialize(&self, options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/bounded_min/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ use vortex_error::VortexExpect;
use vortex_error::VortexResult;
use vortex_error::vortex_ensure;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand Down Expand Up @@ -79,7 +80,8 @@ impl AggregateFnVTable for BoundedMin {
type Partial = BoundedMinPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.bounded_min")
static ID: CachedId = CachedId::new("vortex.bounded_min");
*ID
}

fn serialize(&self, options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/count/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ mod grouped;
pub(crate) use grouped::CountGroupedKernel;
use vortex_error::VortexExpect;
use vortex_error::VortexResult;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand Down Expand Up @@ -41,7 +42,8 @@ impl AggregateFnVTable for Count {
type Partial = CountPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.count")
static ID: CachedId = CachedId::new("vortex.count");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/first/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
// SPDX-FileCopyrightText: Copyright the Vortex contributors

use vortex_error::VortexResult;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand Down Expand Up @@ -40,7 +41,8 @@ impl AggregateFnVTable for First {
type Partial = FirstPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.first")
static ID: CachedId = CachedId::new("vortex.first");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/is_constant/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ mod varbin;
use vortex_error::VortexExpect;
use vortex_error::VortexResult;
use vortex_error::vortex_bail;
use vortex_session::registry::CachedId;

use self::bool::check_bool_constant;
use self::decimal::check_decimal_constant;
Expand Down Expand Up @@ -258,7 +259,8 @@ impl AggregateFnVTable for IsConstant {
type Partial = IsConstantPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.is_constant")
static ID: CachedId = CachedId::new("vortex.is_constant");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/is_sorted/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ use std::fmt::Formatter;

use vortex_error::VortexExpect;
use vortex_error::VortexResult;
use vortex_session::registry::CachedId;

use self::bool::check_bool_sorted;
use self::decimal::check_decimal_sorted;
Expand Down Expand Up @@ -232,7 +233,8 @@ impl AggregateFnVTable for IsSorted {
type Partial = IsSortedPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.is_sorted")
static ID: CachedId = CachedId::new("vortex.is_sorted");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/last/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
// SPDX-FileCopyrightText: Copyright the Vortex contributors

use vortex_error::VortexResult;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand Down Expand Up @@ -40,7 +41,8 @@ impl AggregateFnVTable for Last {
type Partial = LastPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.last")
static ID: CachedId = CachedId::new("vortex.last");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/max/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
use vortex_error::VortexExpect;
use vortex_error::VortexResult;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand Down Expand Up @@ -76,7 +77,8 @@ impl AggregateFnVTable for Max {
type Partial = MaxPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.max")
static ID: CachedId = CachedId::new("vortex.max");
*ID
}

fn serialize(&self, options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/mean/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@

use vortex_error::VortexResult;
use vortex_error::vortex_bail;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::ExecutionCtx;
Expand Down Expand Up @@ -62,7 +63,8 @@ impl BinaryCombined for Mean {
type Right = Count;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.mean")
static ID: CachedId = CachedId::new("vortex.mean");
*ID
}

fn left(&self) -> Sum {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/min/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
use vortex_error::VortexExpect;
use vortex_error::VortexResult;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand Down Expand Up @@ -76,7 +77,8 @@ impl AggregateFnVTable for Min {
type Partial = MinPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.min")
static ID: CachedId = CachedId::new("vortex.min");
*ID
}

fn serialize(&self, options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/min_max/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ use vortex_error::VortexExpect;
use vortex_error::VortexResult;
use vortex_error::vortex_bail;
use vortex_error::vortex_panic;
use vortex_session::registry::CachedId;

use self::bool::accumulate_bool;
use self::decimal::accumulate_decimal;
Expand Down Expand Up @@ -291,7 +292,8 @@ impl AggregateFnVTable for MinMax {
type Partial = MinMaxPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.min_max")
static ID: CachedId = CachedId::new("vortex.min_max");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/nan_count/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ use vortex_error::VortexResult;
use vortex_error::vortex_bail;
use vortex_error::vortex_err;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use self::primitive::accumulate_primitive;
use crate::ArrayRef;
Expand Down Expand Up @@ -84,7 +85,8 @@ impl AggregateFnVTable for NanCount {
type Partial = u64;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.nan_count")
static ID: CachedId = CachedId::new("vortex.nan_count");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/null_count/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ use vortex_error::VortexExpect;
use vortex_error::VortexResult;
use vortex_error::vortex_err;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Columnar;
Expand Down Expand Up @@ -59,7 +60,8 @@ impl AggregateFnVTable for NullCount {
type Partial = u64;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.null_count")
static ID: CachedId = CachedId::new("vortex.null_count");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/aggregate_fn/fns/sum/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ use vortex_error::vortex_bail;
use vortex_error::vortex_err;
use vortex_error::vortex_panic;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use self::bool::accumulate_bool;
use self::constant::multiply_constant;
Expand Down Expand Up @@ -81,7 +82,8 @@ impl AggregateFnVTable for Sum {
type Partial = SumPartial;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.sum")
static ID: CachedId = CachedId::new("vortex.sum");
*ID
}

fn serialize(&self, options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@ use vortex_error::vortex_bail;
use vortex_error::vortex_err;
use vortex_mask::Mask;
use vortex_session::VortexSession;
use vortex_session::registry::CachedId;

use crate::ArrayRef;
use crate::Canonical;
Expand Down Expand Up @@ -101,7 +102,8 @@ impl AggregateFnVTable for UncompressedSizeInBytes {
type Partial = u64;

fn id(&self) -> AggregateFnId {
AggregateFnId::new("vortex.uncompressed_size_in_bytes")
static ID: CachedId = CachedId::new("vortex.uncompressed_size_in_bytes");
*ID
}

fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/extension/datetime/date.rs
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ use vortex_error::VortexResult;
use vortex_error::vortex_bail;
use vortex_error::vortex_ensure;
use vortex_error::vortex_err;
use vortex_session::registry::CachedId;

use crate::dtype::DType;
use crate::dtype::Nullability;
Expand Down Expand Up @@ -79,7 +80,8 @@ impl ExtVTable for Date {
type NativeValue<'a> = DateValue;

fn id(&self) -> ExtId {
ExtId::new("vortex.date")
static ID: CachedId = CachedId::new("vortex.date");
*ID
}

fn serialize_metadata(&self, metadata: &Self::Metadata) -> VortexResult<Vec<u8>> {
Expand Down
4 changes: 3 additions & 1 deletion vortex-array/src/extension/datetime/time.rs
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ use vortex_error::VortexResult;
use vortex_error::vortex_bail;
use vortex_error::vortex_ensure;
use vortex_error::vortex_err;
use vortex_session::registry::CachedId;

use crate::dtype::DType;
use crate::dtype::Nullability;
Expand Down Expand Up @@ -80,7 +81,8 @@ impl ExtVTable for Time {
type NativeValue<'a> = TimeValue;

fn id(&self) -> ExtId {
ExtId::new("vortex.time")
static ID: CachedId = CachedId::new("vortex.time");
*ID
}

fn serialize_metadata(&self, metadata: &Self::Metadata) -> VortexResult<Vec<u8>> {
Expand Down
Loading
Loading