Skip to content

Commit 50e33d0

Browse files
vitstnKamil Khamitov
authored andcommitted
YQL-19495 stable hll hash
commit_hash:10191c9cf1aa6e4fb1f41bfa682554c7248a446b
1 parent 090b058 commit 50e33d0

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

yql/essentials/mount/lib/yql/aggregate.yqls

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -382,8 +382,8 @@
382382
# list_type:type
383383
# doesn't support optional values
384384
(let hyperloglog_traits_factory_raw (lambda '(list_type precision) (block '(
385-
(let init (lambda '(value parent) (NamedApply (Udf 'HyperLogLog.Create) '((Apply (Udf 'Digest.MurMurHash) (Pickle value)) precision) (AsStruct) (DependsOn parent))))
386-
(let update (lambda '(value state parent) (NamedApply (Udf 'HyperLogLog.AddValue) '(state (Apply (Udf 'Digest.MurMurHash) (Pickle value))) (AsStruct) (DependsOn parent))))
385+
(let init (lambda '(value parent) (NamedApply (Udf 'HyperLogLog.Create) '((Apply (Udf 'Digest.MurMurHash) (StablePickle value)) precision) (AsStruct) (DependsOn parent))))
386+
(let update (lambda '(value state parent) (NamedApply (Udf 'HyperLogLog.AddValue) '(state (Apply (Udf 'Digest.MurMurHash) (StablePickle value))) (AsStruct) (DependsOn parent))))
387387
(let save (lambda '(state) (Apply (Udf 'HyperLogLog.Serialize) state)))
388388
(let load (lambda '(state) (Apply (Udf 'HyperLogLog.Deserialize) state)))
389389
(let merge (lambda '(one two) (Apply (Udf 'HyperLogLog.Merge) one two)))

yql/essentials/mount/lib/yql/window.yqls

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -368,8 +368,8 @@
368368
# list_type:type
369369
# doesn't support optional values
370370
(let hyperloglog_traits_factory_raw (lambda '(list_type n) (block '(
371-
(let init (lambda '(value parent) (NamedApply (Udf 'HyperLogLog.Create) '((Apply (Udf 'Digest.MurMurHash) (Pickle value)) n) (AsStruct) (DependsOn parent))))
372-
(let update (lambda '(value state parent) (NamedApply (Udf 'HyperLogLog.AddValue) '(state (Apply (Udf 'Digest.MurMurHash) (Pickle value))) (AsStruct) (DependsOn parent))))
371+
(let init (lambda '(value parent) (NamedApply (Udf 'HyperLogLog.Create) '((Apply (Udf 'Digest.MurMurHash) (StablePickle value)) n) (AsStruct) (DependsOn parent))))
372+
(let update (lambda '(value state parent) (NamedApply (Udf 'HyperLogLog.AddValue) '(state (Apply (Udf 'Digest.MurMurHash) (StablePickle value))) (AsStruct) (DependsOn parent))))
373373
(let shift (lambda '(value state) (Void)))
374374
(let current (lambda '(state) (Apply (Udf 'HyperLogLog.GetResult) state)))
375375
(return (WindowTraits (ListItemType list_type) init update shift current (Null)))

0 commit comments

Comments
 (0)