hash

Author: findepi

datafusion-examples/examples/advanced_udf.rs

@@ -210,6 +210,7 @@ impl ScalarUDFImpl for PowUdf {
     fn hash_value(&self) -> u64 {
         let Self { signature, aliases } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         signature.hash(&mut hasher);
         aliases.hash(&mut hasher);
         hasher.finish()

datafusion-examples/examples/function_factory.rs

@@ -179,6 +179,7 @@ impl ScalarUDFImpl for ScalarFunctionWrapper {
             return_type,
         } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         name.hash(&mut hasher);
         expr.hash(&mut hasher);
         signature.hash(&mut hasher);

datafusion/core/tests/user_defined/user_defined_scalar_functions.rs

@@ -239,6 +239,7 @@ impl ScalarUDFImpl for Simple0ArgsScalarUDF {
             return_type,
         } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         name.hash(&mut hasher);
         signature.hash(&mut hasher);
         return_type.hash(&mut hasher);
@@ -606,6 +607,7 @@ impl ScalarUDFImpl for AddIndexToStringVolatileScalarUDF {
             return_type,
         } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         name.hash(&mut hasher);
         signature.hash(&mut hasher);
         return_type.hash(&mut hasher);
@@ -1053,6 +1055,7 @@ impl ScalarUDFImpl for ScalarFunctionWrapper {
             return_type,
         } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         name.hash(&mut hasher);
         expr.hash(&mut hasher);
         signature.hash(&mut hasher);
@@ -1788,6 +1791,7 @@ impl ScalarUDFImpl for ExtensionBasedUdf {
     fn hash_value(&self) -> u64 {
         let Self { name, signature } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         name.hash(&mut hasher);
         signature.hash(&mut hasher);
         hasher.finish()

datafusion/expr/src/expr_fn.rs

@@ -500,6 +500,7 @@ impl ScalarUDFImpl for SimpleScalarUDF {
             fun,
         } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         name.hash(&mut hasher);
         signature.hash(&mut hasher);
         return_type.hash(&mut hasher);
@@ -654,6 +655,7 @@ impl AggregateUDFImpl for SimpleAggregateUDF {
             state_fields,
         } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         name.hash(&mut hasher);
         signature.hash(&mut hasher);
         return_type.hash(&mut hasher);
@@ -781,6 +783,7 @@ impl WindowUDFImpl for SimpleWindowUDF {
             partition_evaluator_factory,
         } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         name.hash(&mut hasher);
         signature.hash(&mut hasher);
         return_type.hash(&mut hasher);

datafusion/expr/src/test/function_stub.rs

@@ -284,6 +284,7 @@ impl AggregateUDFImpl for Count {
     fn hash_value(&self) -> u64 {
         let Self { signature, aliases } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         signature.hash(&mut hasher);
         aliases.hash(&mut hasher);
         hasher.finish()
@@ -518,6 +519,7 @@ impl AggregateUDFImpl for Avg {
     fn hash_value(&self) -> u64 {
         let Self { signature, aliases } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         signature.hash(&mut hasher);
         aliases.hash(&mut hasher);
         hasher.finish()

datafusion/ffi/src/udaf/mod.rs

@@ -575,6 +575,7 @@ impl AggregateUDFImpl for ForeignAggregateUDF {
             udaf,
         } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         signature.hash(&mut hasher);
         aliases.hash(&mut hasher);
         std::ptr::hash(udaf, &mut hasher);

datafusion/ffi/src/udf/mod.rs

@@ -433,6 +433,7 @@ impl ScalarUDFImpl for ForeignScalarUDF {
             signature,
         } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         name.hash(&mut hasher);
         aliases.hash(&mut hasher);
         std::ptr::hash(udf, &mut hasher);

datafusion/ffi/src/udwf/mod.rs

@@ -359,6 +359,7 @@ impl WindowUDFImpl for ForeignWindowUDF {
             signature,
         } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         name.hash(&mut hasher);
         aliases.hash(&mut hasher);
         std::ptr::hash(udf, &mut hasher);

datafusion/functions-aggregate/src/approx_percentile_cont_with_weight.rs

@@ -206,6 +206,7 @@ impl AggregateUDFImpl for ApproxPercentileContWithWeight {
             approx_percentile_cont,
         } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         signature.hash(&mut hasher);
         hasher.write_u64(approx_percentile_cont.hash_value());
         hasher.finish()

datafusion/functions-aggregate/src/average.rs

@@ -322,6 +322,7 @@ impl AggregateUDFImpl for Avg {
     fn hash_value(&self) -> u64 {
         let Self { signature, aliases } = self;
         let mut hasher = DefaultHasher::new();
+        std::any::type_name::<Self>().hash(&mut hasher);
         signature.hash(&mut hasher);
         aliases.hash(&mut hasher);
         hasher.finish()