CachedIds for functions

vortex-array/src/scalar_fn/fns/between/mod.rs

@@ -13,6 +13,7 @@ use vortex_error::VortexResult;
 use vortex_error::vortex_bail;
 use vortex_proto::expr as pb;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::Canonical;
@@ -176,7 +177,8 @@ impl ScalarFnVTable for Between {
     type Options = BetweenOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.between")
+        static ID: CachedId = CachedId::new("vortex.between");
+        *ID
     }
 
     fn serialize(&self, instance: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/binary/mod.rs

@@ -12,6 +12,7 @@ use vortex_error::VortexResult;
 use vortex_error::vortex_bail;
 use vortex_proto::expr as pb;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -52,7 +53,8 @@ impl ScalarFnVTable for Binary {
     type Options = Operator;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.binary")
+        static ID: CachedId = CachedId::new("vortex.binary");
+        *ID
     }
 
     fn serialize(&self, instance: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/case_when.rs

@@ -22,6 +22,7 @@ use vortex_mask::AllOr;
 use vortex_mask::Mask;
 use vortex_proto::expr as pb;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -79,7 +80,8 @@ impl ScalarFnVTable for CaseWhen {
     type Options = CaseWhenOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.case_when")
+        static ID: CachedId = CachedId::new("vortex.case_when");
+        *ID
     }
 
     fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/cast/mod.rs

@@ -12,6 +12,7 @@ use vortex_error::vortex_bail;
 use vortex_error::vortex_err;
 use vortex_proto::expr as pb;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::AnyColumnar;
 use crate::ArrayRef;
@@ -53,7 +54,8 @@ impl ScalarFnVTable for Cast {
     type Options = DType;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.cast")
+        static ID: CachedId = CachedId::new("vortex.cast");
+        *ID
     }
 
     fn serialize(&self, dtype: &DType) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/dynamic.rs

@@ -12,6 +12,7 @@ use parking_lot::Mutex;
 use vortex_error::VortexExpect;
 use vortex_error::VortexResult;
 use vortex_error::vortex_bail;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -46,7 +47,8 @@ impl ScalarFnVTable for DynamicComparison {
     type Options = DynamicComparisonExpr;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::from("vortex.dynamic")
+        static ID: CachedId = CachedId::new("vortex.dynamic");
+        *ID
     }
 
     fn arity(&self, _options: &Self::Options) -> Arity {

vortex-array/src/scalar_fn/fns/fill_null/mod.rs

@@ -9,6 +9,7 @@ use vortex_error::vortex_bail;
 use vortex_error::vortex_ensure;
 use vortex_error::vortex_err;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::AnyColumnar;
 use crate::ArrayRef;
@@ -37,7 +38,8 @@ impl ScalarFnVTable for FillNull {
     type Options = EmptyOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.fill_null")
+        static ID: CachedId = CachedId::new("vortex.fill_null");
+        *ID
     }
 
     fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/get_item.rs

@@ -8,6 +8,7 @@ use vortex_error::VortexResult;
 use vortex_error::vortex_err;
 use vortex_proto::expr as pb;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -44,7 +45,8 @@ impl ScalarFnVTable for GetItem {
     type Options = FieldName;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.get_item")
+        static ID: CachedId = CachedId::new("vortex.get_item");
+        *ID
     }
 
     fn serialize(&self, instance: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/is_not_null.rs

@@ -6,6 +6,7 @@ use std::fmt::Formatter;
 use vortex_array::scalar_fn::internal::row_count::RowCount;
 use vortex_error::VortexResult;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -34,7 +35,8 @@ impl ScalarFnVTable for IsNotNull {
     type Options = EmptyOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.is_not_null")
+        static ID: CachedId = CachedId::new("vortex.is_not_null");
+        *ID
     }
 
     fn serialize(&self, _instance: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/is_null.rs

@@ -3,6 +3,7 @@
 
 use vortex_error::VortexResult;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -32,7 +33,8 @@ impl ScalarFnVTable for IsNull {
     type Options = EmptyOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::from("vortex.is_null")
+        static ID: CachedId = CachedId::new("vortex.is_null");
+        *ID
     }
 
     fn serialize(&self, _instance: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/like/mod.rs

@@ -13,6 +13,7 @@ use vortex_error::VortexResult;
 use vortex_error::vortex_bail;
 use vortex_proto::expr as pb;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -63,7 +64,8 @@ impl ScalarFnVTable for Like {
     type Options = LikeOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.like")
+        static ID: CachedId = CachedId::new("vortex.like");
+        *ID
     }
 
     fn serialize(&self, instance: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/list_contains/mod.rs

@@ -14,6 +14,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 vortex_utils::iter::ReduceBalancedIterExt;
 
 use crate::ArrayRef;
@@ -61,7 +62,8 @@ impl ScalarFnVTable for ListContains {
     type Options = EmptyOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.list.contains")
+        static ID: CachedId = CachedId::new("vortex.list.contains");
+        *ID
     }
 
     fn serialize(&self, _instance: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/literal.rs

@@ -8,6 +8,7 @@ use vortex_error::VortexResult;
 use vortex_error::vortex_err;
 use vortex_proto::expr as pb;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -38,7 +39,8 @@ impl ScalarFnVTable for Literal {
     type Options = Scalar;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::from("vortex.literal")
+        static ID: CachedId = CachedId::new("vortex.literal");
+        *ID
     }
 
     fn serialize(&self, instance: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/mask/mod.rs

@@ -8,6 +8,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::Canonical;
@@ -44,7 +45,8 @@ impl ScalarFnVTable for Mask {
     type Options = EmptyOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.mask")
+        static ID: CachedId = CachedId::new("vortex.mask");
+        *ID
     }
 
     fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/merge.rs

@@ -11,6 +11,7 @@ use vortex_error::VortexExpect;
 use vortex_error::VortexResult;
 use vortex_error::vortex_bail;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 use vortex_utils::aliases::hash_set::HashSet;
 
 use crate::ArrayRef;
@@ -51,7 +52,8 @@ impl ScalarFnVTable for Merge {
     type Options = DuplicateHandling;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::from("vortex.merge")
+        static ID: CachedId = CachedId::new("vortex.merge");
+        *ID
     }
 
     fn serialize(&self, instance: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/not/mod.rs

@@ -7,6 +7,7 @@ pub use kernel::*;
 use vortex_error::VortexResult;
 use vortex_error::vortex_bail;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -33,7 +34,8 @@ impl ScalarFnVTable for Not {
     type Options = EmptyOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.not")
+        static ID: CachedId = CachedId::new("vortex.not");
+        *ID
     }
 
     fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/pack.rs

@@ -11,6 +11,7 @@ use prost::Message;
 use vortex_error::VortexResult;
 use vortex_proto::expr as pb;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -55,7 +56,8 @@ impl ScalarFnVTable for Pack {
     type Options = PackOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::from("vortex.pack")
+        static ID: CachedId = CachedId::new("vortex.pack");
+        *ID
     }
 
     fn serialize(&self, instance: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/root.rs

@@ -6,6 +6,7 @@ use std::fmt::Formatter;
 use vortex_error::VortexResult;
 use vortex_error::vortex_bail;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -30,7 +31,8 @@ impl ScalarFnVTable for Root {
     type Options = EmptyOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.root")
+        static ID: CachedId = CachedId::new("vortex.root");
+        *ID
     }
 
     fn serialize(&self, _instance: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/select.rs

@@ -14,6 +14,7 @@ use vortex_proto::expr::FieldNames as ProtoFieldNames;
 use vortex_proto::expr::SelectOpts;
 use vortex_proto::expr::select_opts::Opts;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -48,7 +49,8 @@ impl ScalarFnVTable for Select {
     type Options = FieldSelection;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::from("vortex.select")
+        static ID: CachedId = CachedId::new("vortex.select");
+        *ID
     }
 
     fn serialize(&self, instance: &FieldSelection) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/stat.rs

@@ -8,6 +8,7 @@ use std::fmt::Formatter;
 
 use vortex_error::VortexResult;
 use vortex_error::vortex_bail;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -82,7 +83,8 @@ impl ScalarFnVTable for StatFn {
     type Options = StatOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.stat")
+        static ID: CachedId = CachedId::new("vortex.stat");
+        *ID
     }
 
     fn arity(&self, _options: &Self::Options) -> Arity {

vortex-array/src/scalar_fn/fns/variant_get/mod.rs

@@ -12,6 +12,7 @@ use vortex_error::vortex_err;
 use vortex_proto::expr as pb;
 use vortex_proto::expr::variant_path_element;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 use vortex_utils::aliases::StringEscape;
 
 use crate::ArrayRef;
@@ -45,7 +46,8 @@ impl ScalarFnVTable for VariantGet {
     type Options = VariantGetOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.variant_get")
+        static ID: CachedId = CachedId::new("vortex.variant_get");
+        *ID
     }
 
     fn serialize(&self, options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/fns/zip/mod.rs

@@ -12,6 +12,7 @@ use vortex_error::vortex_ensure;
 use vortex_mask::Mask;
 use vortex_mask::MaskValues;
 use vortex_session::VortexSession;
+use vortex_session::registry::CachedId;
 
 use crate::ArrayRef;
 use crate::ExecutionCtx;
@@ -46,7 +47,8 @@ impl ScalarFnVTable for Zip {
     type Options = EmptyOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::new("vortex.zip")
+        static ID: CachedId = CachedId::new("vortex.zip");
+        *ID
     }
 
     fn serialize(&self, _options: &Self::Options) -> VortexResult<Option<Vec<u8>>> {

vortex-array/src/scalar_fn/internal/row_count.rs

@@ -21,6 +21,7 @@ use vortex_array::scalar_fn::ScalarFnVTable;
 use vortex_error::VortexResult;
 use vortex_error::vortex_bail;
 use vortex_error::vortex_ensure;
+use vortex_session::registry::CachedId;
 
 /// Zero-argument placeholder for the row count of the current evaluation scope.
 ///
@@ -48,7 +49,8 @@ impl ScalarFnVTable for RowCount {
     type Options = EmptyOptions;
 
     fn id(&self) -> ScalarFnId {
-        ScalarFnId::from("vortex.row_count")
+        static ID: CachedId = CachedId::new("vortex.row_count");
+        *ID
     }
 
     fn arity(&self, _options: &Self::Options) -> Arity {