summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorvvvv <[email protected]>2025-02-27 10:27:59 +0300
committervvvv <[email protected]>2025-02-27 10:49:34 +0300
commit9e80b85daf561409cf07a1a77f23545006cdbe16 (patch)
tree57e3b7c4444a1a4e8208f59072c84f836c54bbf8
parent6678c9df5d7f6691bb26d817924a09f51fcbd09a (diff)
YQL-19495 stable hll hash
commit_hash:10191c9cf1aa6e4fb1f41bfa682554c7248a446b
-rwxr-xr-xyql/essentials/mount/lib/yql/aggregate.yqls4
-rwxr-xr-xyql/essentials/mount/lib/yql/window.yqls4
2 files changed, 4 insertions, 4 deletions
diff --git a/yql/essentials/mount/lib/yql/aggregate.yqls b/yql/essentials/mount/lib/yql/aggregate.yqls
index e687adbf801..3518d0af8db 100755
--- a/yql/essentials/mount/lib/yql/aggregate.yqls
+++ b/yql/essentials/mount/lib/yql/aggregate.yqls
@@ -382,8 +382,8 @@
# list_type:type
# doesn't support optional values
(let hyperloglog_traits_factory_raw (lambda '(list_type precision) (block '(
- (let init (lambda '(value parent) (NamedApply (Udf 'HyperLogLog.Create) '((Apply (Udf 'Digest.MurMurHash) (Pickle value)) precision) (AsStruct) (DependsOn parent))))
- (let update (lambda '(value state parent) (NamedApply (Udf 'HyperLogLog.AddValue) '(state (Apply (Udf 'Digest.MurMurHash) (Pickle value))) (AsStruct) (DependsOn parent))))
+ (let init (lambda '(value parent) (NamedApply (Udf 'HyperLogLog.Create) '((Apply (Udf 'Digest.MurMurHash) (StablePickle value)) precision) (AsStruct) (DependsOn parent))))
+ (let update (lambda '(value state parent) (NamedApply (Udf 'HyperLogLog.AddValue) '(state (Apply (Udf 'Digest.MurMurHash) (StablePickle value))) (AsStruct) (DependsOn parent))))
(let save (lambda '(state) (Apply (Udf 'HyperLogLog.Serialize) state)))
(let load (lambda '(state) (Apply (Udf 'HyperLogLog.Deserialize) state)))
(let merge (lambda '(one two) (Apply (Udf 'HyperLogLog.Merge) one two)))
diff --git a/yql/essentials/mount/lib/yql/window.yqls b/yql/essentials/mount/lib/yql/window.yqls
index dd1f537bc9a..32c47b2dfd9 100755
--- a/yql/essentials/mount/lib/yql/window.yqls
+++ b/yql/essentials/mount/lib/yql/window.yqls
@@ -368,8 +368,8 @@
# list_type:type
# doesn't support optional values
(let hyperloglog_traits_factory_raw (lambda '(list_type n) (block '(
- (let init (lambda '(value parent) (NamedApply (Udf 'HyperLogLog.Create) '((Apply (Udf 'Digest.MurMurHash) (Pickle value)) n) (AsStruct) (DependsOn parent))))
- (let update (lambda '(value state parent) (NamedApply (Udf 'HyperLogLog.AddValue) '(state (Apply (Udf 'Digest.MurMurHash) (Pickle value))) (AsStruct) (DependsOn parent))))
+ (let init (lambda '(value parent) (NamedApply (Udf 'HyperLogLog.Create) '((Apply (Udf 'Digest.MurMurHash) (StablePickle value)) n) (AsStruct) (DependsOn parent))))
+ (let update (lambda '(value state parent) (NamedApply (Udf 'HyperLogLog.AddValue) '(state (Apply (Udf 'Digest.MurMurHash) (StablePickle value))) (AsStruct) (DependsOn parent))))
(let shift (lambda '(value state) (Void)))
(let current (lambda '(state) (Apply (Udf 'HyperLogLog.GetResult) state)))
(return (WindowTraits (ListItemType list_type) init update shift current (Null)))