diff options
| author | Maxim Yurchuk <maxim-yurchuk@ydb.tech> | 2024-12-12 15:00:43 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-12-12 15:00:43 +0000 |
| commit | 42701242eaf5be980cb935631586d0e90b82641c (patch) | |
| tree | 6dbf5fcd37d3c16591e196c4a69d166e3ab3a398 /yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.yql | |
| parent | 7f5a9f394dbd9ac290cabbb7977538656b3a541e (diff) | |
| parent | f7c04b5876af3d16849ab5e3079c0eabbd4e3a00 (diff) | |
| download | ydb-42701242eaf5be980cb935631586d0e90b82641c.tar.gz | |
Merge pull request #12554 from vitalyisaev2/YQ-3839.with_rightlib.3
Import from Arcadia + YDB FQ: turning gateways_config.proto into a file without external dependencies
Diffstat (limited to 'yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.yql')
| -rw-r--r-- | yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.yql | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.yql b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.yql index 3df99f0f47..dc7c70cea6 100644 --- a/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.yql +++ b/yql/essentials/tests/s-expressions/suites/Optimizers/FuseLMapAfterLReduce.yql @@ -28,7 +28,7 @@ (let inputType (CallableArgumentType (TypeOf (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@ def f(input,x): for i in list(input): - d = i.__dict__ + d = {name: getattr(i, name) for name in i.__class__.__match_args__} d["pass"] = x yield d @@))) '0)) @@ -36,7 +36,7 @@ def f(input,x): (return (Apply (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@ def f(input,x): for i in list(input): - d = i.__dict__ + d = {name: getattr(i, name) for name in i.__class__.__match_args__} d["pass"] = x yield d @@)) inputRowsList (Int32 '"1"))) @@ -49,7 +49,7 @@ def f(input,x): (let inputType (CallableArgumentType (TypeOf (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@ def f(input,x): for i in list(input): - d = i.__dict__ + d = {name: getattr(i, name) for name in i.__class__.__match_args__} d["pass"] = x yield d @@))) '0)) @@ -57,7 +57,7 @@ def f(input,x): (return (Apply (ScriptUdf 'Python3 '"f" (CallableType '() '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((StreamType (StructType '('"cnt" (DataType 'Uint64)) '('"pass" (DataType 'Int32)) '('"skey" (DataType 'Uint32))))) '((DataType 'Int32))) (String '@@ def f(input,x): for i in list(input): - d = i.__dict__ + d = {name: getattr(i, name) for name in i.__class__.__match_args__} d["pass"] = x yield d @@)) inputRowsList (Int32 '"2"))) |