diff options
| author | vvvv <[email protected]> | 2025-02-27 10:27:59 +0300 |
|---|---|---|
| committer | vvvv <[email protected]> | 2025-02-27 10:49:34 +0300 |
| commit | 9e80b85daf561409cf07a1a77f23545006cdbe16 (patch) | |
| tree | 57e3b7c4444a1a4e8208f59072c84f836c54bbf8 | |
| parent | 6678c9df5d7f6691bb26d817924a09f51fcbd09a (diff) | |
YQL-19495 stable hll hash
commit_hash:10191c9cf1aa6e4fb1f41bfa682554c7248a446b
| -rwxr-xr-x | yql/essentials/mount/lib/yql/aggregate.yqls | 4 | ||||
| -rwxr-xr-x | yql/essentials/mount/lib/yql/window.yqls | 4 |
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))) |
