Intermediate changes

commit_hash:27af5f8a0a7836d78ffdc205213f07f79dd9f7ad

1 files changed, 107 insertions, 0 deletions

diff --git a/yql/essentials/tests/s-expressions/suites/Aggregation/AggregateSameDistinct.yqls b/yql/essentials/tests/s-expressions/suites/Aggregation/AggregateSameDistinct.yqls
new file mode 100644
index 0000000000..9f4fb01757
--- /dev/null
+++ b/yql/essentials/tests/s-expressions/suites/Aggregation/AggregateSameDistinct.yqls
@@ -0,0 +1,107 @@
+(
+(let $1 world)
+(let $2 (DataSource '"yt" '"plato"))
+(let $3 (String '"Input"))
+(let $4 '('table $3))
+(let $5 (Key $4))
+(let $6 '('"key"))
+(let $7 '())
+(let $8 (Read! $1 $2 $5 $6 $7))
+(let $9 (Left! $8))
+(let $10 (DataSink 'result))
+(let $11 (Key))
+(let $12 (Right! $8))
+(let $13 '())
+(let $14 (TypeOf $12))
+(let $15 (ListItemType $14))
+(let $16 (StructMemberType $15 '"key"))
+(let $17 (lambda '($49) (block '(
+  (let $51 (Exists $49))
+  (let $52 (Convert $51 'Uint64))
+  (return $52)
+))))
+(let $18 (lambda '($53 $54) (block '(
+  (let $56 (Exists $53))
+  (let $57 (Convert $56 'Uint64))
+  (let $58 (lambda '($60 $61) (block '(
+    (let $63 (+ $60 $61))
+    (return $63)
+  ))))
+  (let $59 (OptionalReduce $54 $57 $58))
+  (return $59)
+))))
+(let $19 (lambda '($64) (block '(
+  (return $64)
+))))
+(let $20 (lambda '($66) (block '(
+  (return $66)
+))))
+(let $21 (lambda '($68 $69) (block '(
+  (let $71 (lambda '($73 $74) (block '(
+    (let $76 (+ $73 $74))
+    (return $76)
+  ))))
+  (let $72 (OptionalReduce $68 $69 $71))
+  (return $72)
+))))
+(let $22 (lambda '($77) (block '(
+  (return $77)
+))))
+(let $23 (AggregationTraits $16 $17 $18 $19 $20 $21 $22 (Null)))
+(let $24 '('Count0 $23 '"key"))
+(let $25 (TypeOf $12))
+(let $26 (ListItemType $25))
+(let $27 (StructMemberType $26 '"key"))
+(let $28 (lambda '($79) (block '(
+  (return $79)
+))))
+(let $29 (lambda '($81 $82) (block '(
+  (let $84 (lambda '($86 $87) (block '(
+    (let $89 (Min $86 $87))
+    (return $89)
+  ))))
+  (let $85 (OptionalReduce $82 $81 $84))
+  (return $85)
+))))
+(let $30 (lambda '($90) (block '(
+  (return $90)
+))))
+(let $31 (lambda '($92) (block '(
+  (return $92)
+))))
+(let $32 (lambda '($94 $95) (block '(
+  (let $97 (lambda '($99 $100) (block '(
+    (let $102 (Min $99 $100))
+    (return $102)
+  ))))
+  (let $98 (OptionalReduce $94 $95 $97))
+  (return $98)
+))))
+(let $33 (lambda '($103) (block '(
+  (return $103)
+))))
+(let $34 (AggregationTraits $27 $28 $29 $30 $31 $32 $33 (Null)))
+(let $35 '('Min1 $34 '"key"))
+(let $36 '($24 $35))
+(let $37 (Aggregate $12 $13 $36))
+(let $38 (lambda '($105) (block '(
+  (let $107 (Struct))
+  (let $108 (Member $105 'Count0))
+  (let $109 (AddMember $107 '"column0" $108))
+  (let $110 (Member $105 'Min1))
+  (let $111 (AddMember $109 '"column1" $110))
+  (let $112 (AsList $111))
+  (return $112)
+))))
+(let $39 (FlatMap $37 $38))
+(let $40 '('type))
+(let $41 '('autoref))
+(let $42 '('"column0" '"column1"))
+(let $43 '('columns $42))
+(let $44 '($40 $41 $43))
+(let $45 (Write! $9 $10 $11 $39 $44))
+(let $46 (Commit! $45 $10))
+(let $47 (DataSink '"yt" '"plato"))
+(let $48 (Commit! $46 $47))
+(return $48)
+)