Skip to content

Commit bcc6200

Browse files
APozdniakovvokayndzop
APozdniakov
and
vokayndzop
authored
[YQ-4799] to stable (#28227)
Co-authored-by: vokayndzop <vokayndzop@yandex-team.com>
1 parent 4d45f48 commit bcc6200

File tree

100 files changed

+1666
-214
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

100 files changed

+1666
-214
lines changed

‎ydb/library/yql/dq/opt/dq_opt_hopping.cpp‎

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -157,12 +157,13 @@ TMaybeNode<TExprBase> RewriteAsHoppingWindowFullOutput(
157157
.FinishHandler(finishLambda)
158158
.SaveHandler(saveLambda)
159159
.LoadHandler(loadLambda)
160-
.template WatermarkMode<TCoAtom>().Build(ToString(*enableWatermarks));
160+
.WatermarkMode<TCoAtom>().Build(ToString(*enableWatermarks))
161+
.HoppingColumn<TCoAtom>().Build(hopTraits.Column);
161162

162163
if (*enableWatermarks) {
163164
const auto hop = hopTraits.Hop;
164165
const auto delay = lateArrivalDelay ? (lateArrivalDelay.MicroSeconds() + hop - 1) / hop * hop : hop;
165-
multiHoppingCoreBuilder.template Delay<TCoInterval>()
166+
multiHoppingCoreBuilder.Delay<TCoInterval>()
166167
.Literal().Build(ToString(delay))
167168
.Build();
168169
} else {
@@ -181,9 +182,9 @@ TMaybeNode<TExprBase> RewriteAsHoppingWindowFullOutput(
181182
.SortKeySelectorLambda(timeExtractorLambda)
182183
.ListHandlerLambda()
183184
.Args(streamArg)
184-
.template Body<TCoForwardList>()
185+
.Body<TCoForwardList>()
185186
.Stream(multiHoppingCoreBuilder
186-
.template Input<TCoIterator>()
187+
.Input<TCoIterator>()
187188
.List(streamArg)
188189
.Build()
189190
.Done())
@@ -208,7 +209,7 @@ TMaybeNode<TExprBase> RewriteAsHoppingWindowFullOutput(
208209
.Args(streamArg)
209210
.Body<TCoMap>()
210211
.Input(multiHoppingCoreBuilder
211-
.template Input<TCoFromFlow>()
212+
.Input<TCoFromFlow>()
212213
.Input(streamArg)
213214
.Build()
214215
.Done())

‎ydb/tests/fq/streaming_optimize/canondata/result.json‎

Lines changed: 119 additions & 63 deletions
Original file line numberDiff line numberDiff line change
@@ -1,170 +1,226 @@
11
{
2-
"test_sql_streaming.test[suites-GroupByHop-default.txt]": {
2+
"test_sql_streaming.test[hop-GroupByHop-default.txt]": {
33
"Ast": {
4-
"uri": "file://test_sql_streaming.test_suites-GroupByHop-default.txt_/ast.txt"
4+
"uri": "file://test_sql_streaming.test_hop-GroupByHop-default.txt_/ast.txt"
55
},
66
"Plan": {
7-
"uri": "file://test_sql_streaming.test_suites-GroupByHop-default.txt_/plan.json"
7+
"uri": "file://test_sql_streaming.test_hop-GroupByHop-default.txt_/plan.json"
88
}
99
},
10-
"test_sql_streaming.test[suites-GroupByHopByStringKey-default.txt]": {
10+
"test_sql_streaming.test[hop-GroupByHopByStringKey-default.txt]": {
1111
"Ast": {
12-
"uri": "file://test_sql_streaming.test_suites-GroupByHopByStringKey-default.txt_/ast.txt"
12+
"uri": "file://test_sql_streaming.test_hop-GroupByHopByStringKey-default.txt_/ast.txt"
1313
},
1414
"Plan": {
15-
"uri": "file://test_sql_streaming.test_suites-GroupByHopByStringKey-default.txt_/plan.json"
15+
"uri": "file://test_sql_streaming.test_hop-GroupByHopByStringKey-default.txt_/plan.json"
1616
}
1717
},
18-
"test_sql_streaming.test[suites-GroupByHopExprKey-default.txt]": {
18+
"test_sql_streaming.test[hop-GroupByHopExprKey-default.txt]": {
1919
"Ast": {
20-
"uri": "file://test_sql_streaming.test_suites-GroupByHopExprKey-default.txt_/ast.txt"
20+
"uri": "file://test_sql_streaming.test_hop-GroupByHopExprKey-default.txt_/ast.txt"
2121
},
2222
"Plan": {
23-
"uri": "file://test_sql_streaming.test_suites-GroupByHopExprKey-default.txt_/plan.json"
23+
"uri": "file://test_sql_streaming.test_hop-GroupByHopExprKey-default.txt_/plan.json"
2424
}
2525
},
26-
"test_sql_streaming.test[suites-GroupByHopListKey-default.txt]": {
26+
"test_sql_streaming.test[hop-GroupByHopListKey-default.txt]": {
2727
"Ast": {
28-
"uri": "file://test_sql_streaming.test_suites-GroupByHopListKey-default.txt_/ast.txt"
28+
"uri": "file://test_sql_streaming.test_hop-GroupByHopListKey-default.txt_/ast.txt"
2929
},
3030
"Plan": {
31-
"uri": "file://test_sql_streaming.test_suites-GroupByHopListKey-default.txt_/plan.json"
31+
"uri": "file://test_sql_streaming.test_hop-GroupByHopListKey-default.txt_/plan.json"
3232
}
3333
},
34-
"test_sql_streaming.test[suites-GroupByHopNoKey-default.txt]": {
34+
"test_sql_streaming.test[hop-GroupByHopNoKey-default.txt]": {
3535
"Ast": {
36-
"uri": "file://test_sql_streaming.test_suites-GroupByHopNoKey-default.txt_/ast.txt"
36+
"uri": "file://test_sql_streaming.test_hop-GroupByHopNoKey-default.txt_/ast.txt"
3737
},
3838
"Plan": {
39-
"uri": "file://test_sql_streaming.test_suites-GroupByHopNoKey-default.txt_/plan.json"
39+
"uri": "file://test_sql_streaming.test_hop-GroupByHopNoKey-default.txt_/plan.json"
4040
}
4141
},
42-
"test_sql_streaming.test[suites-GroupByHopPercentile-default.txt]": {
42+
"test_sql_streaming.test[hop-GroupByHopPercentile-default.txt]": {
4343
"Ast": {
44-
"uri": "file://test_sql_streaming.test_suites-GroupByHopPercentile-default.txt_/ast.txt"
44+
"uri": "file://test_sql_streaming.test_hop-GroupByHopPercentile-default.txt_/ast.txt"
4545
},
4646
"Plan": {
47-
"uri": "file://test_sql_streaming.test_suites-GroupByHopPercentile-default.txt_/plan.json"
47+
"uri": "file://test_sql_streaming.test_hop-GroupByHopPercentile-default.txt_/plan.json"
4848
}
4949
},
50-
"test_sql_streaming.test[suites-GroupByHopTimeExtractorUnusedColumns-default.txt]": {
50+
"test_sql_streaming.test[hop-GroupByHopTimeExtractorUnusedColumns-default.txt]": {
5151
"Ast": {
52-
"uri": "file://test_sql_streaming.test_suites-GroupByHopTimeExtractorUnusedColumns-default.txt_/ast.txt"
52+
"uri": "file://test_sql_streaming.test_hop-GroupByHopTimeExtractorUnusedColumns-default.txt_/ast.txt"
5353
},
5454
"Plan": {
55-
"uri": "file://test_sql_streaming.test_suites-GroupByHopTimeExtractorUnusedColumns-default.txt_/plan.json"
55+
"uri": "file://test_sql_streaming.test_hop-GroupByHopTimeExtractorUnusedColumns-default.txt_/plan.json"
5656
}
5757
},
58-
"test_sql_streaming.test[suites-GroupByHopWithDataWatermarks-default.txt]": {
58+
"test_sql_streaming.test[hop-GroupByHopWithDataWatermarks-default.txt]": {
5959
"Ast": {
60-
"uri": "file://test_sql_streaming.test_suites-GroupByHopWithDataWatermarks-default.txt_/ast.txt"
60+
"uri": "file://test_sql_streaming.test_hop-GroupByHopWithDataWatermarks-default.txt_/ast.txt"
6161
},
6262
"Plan": {
63-
"uri": "file://test_sql_streaming.test_suites-GroupByHopWithDataWatermarks-default.txt_/plan.json"
63+
"uri": "file://test_sql_streaming.test_hop-GroupByHopWithDataWatermarks-default.txt_/plan.json"
6464
}
6565
},
66-
"test_sql_streaming.test[suites-GroupByHoppingWithDataWatermarks-default.txt]": {
66+
"test_sql_streaming.test[hopping_window-GroupByHoppingWindow-default.txt]": {
6767
"Ast": {
68-
"uri": "file://test_sql_streaming.test_suites-GroupByHoppingWithDataWatermarks-default.txt_/ast.txt"
68+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindow-default.txt_/ast.txt"
6969
},
7070
"Plan": {
71-
"uri": "file://test_sql_streaming.test_suites-GroupByHoppingWithDataWatermarks-default.txt_/plan.json"
71+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindow-default.txt_/plan.json"
7272
}
7373
},
74-
"test_sql_streaming.test[suites-ReadTopic-default.txt]": {
74+
"test_sql_streaming.test[hopping_window-GroupByHoppingWindowByStringKey-default.txt]": {
7575
"Ast": {
76-
"uri": "file://test_sql_streaming.test_suites-ReadTopic-default.txt_/ast.txt"
76+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowByStringKey-default.txt_/ast.txt"
7777
},
7878
"Plan": {
79-
"uri": "file://test_sql_streaming.test_suites-ReadTopic-default.txt_/plan.json"
79+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowByStringKey-default.txt_/plan.json"
8080
}
8181
},
82-
"test_sql_streaming.test[suites-ReadTopicGroupWriteToSolomon-default.txt]": {
82+
"test_sql_streaming.test[hopping_window-GroupByHoppingWindowExprKey-default.txt]": {
8383
"Ast": {
84-
"uri": "file://test_sql_streaming.test_suites-ReadTopicGroupWriteToSolomon-default.txt_/ast.txt"
84+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowExprKey-default.txt_/ast.txt"
8585
},
8686
"Plan": {
87-
"uri": "file://test_sql_streaming.test_suites-ReadTopicGroupWriteToSolomon-default.txt_/plan.json"
87+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowExprKey-default.txt_/plan.json"
8888
}
8989
},
90-
"test_sql_streaming.test[suites-ReadTopicWithMetadata-default.txt]": {
90+
"test_sql_streaming.test[hopping_window-GroupByHoppingWindowListKey-default.txt]": {
9191
"Ast": {
92-
"uri": "file://test_sql_streaming.test_suites-ReadTopicWithMetadata-default.txt_/ast.txt"
92+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowListKey-default.txt_/ast.txt"
9393
},
9494
"Plan": {
95-
"uri": "file://test_sql_streaming.test_suites-ReadTopicWithMetadata-default.txt_/plan.json"
95+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowListKey-default.txt_/plan.json"
9696
}
9797
},
98-
"test_sql_streaming.test[suites-ReadTopicWithMetadataInsideFilter-default.txt]": {
98+
"test_sql_streaming.test[hopping_window-GroupByHoppingWindowNoKey-default.txt]": {
9999
"Ast": {
100-
"uri": "file://test_sql_streaming.test_suites-ReadTopicWithMetadataInsideFilter-default.txt_/ast.txt"
100+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowNoKey-default.txt_/ast.txt"
101101
},
102102
"Plan": {
103-
"uri": "file://test_sql_streaming.test_suites-ReadTopicWithMetadataInsideFilter-default.txt_/plan.json"
103+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowNoKey-default.txt_/plan.json"
104104
}
105105
},
106-
"test_sql_streaming.test[suites-ReadTopicWithMetadataNestedDeep-default.txt]": {
106+
"test_sql_streaming.test[hopping_window-GroupByHoppingWindowPercentile-default.txt]": {
107107
"Ast": {
108-
"uri": "file://test_sql_streaming.test_suites-ReadTopicWithMetadataNestedDeep-default.txt_/ast.txt"
108+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowPercentile-default.txt_/ast.txt"
109109
},
110110
"Plan": {
111-
"uri": "file://test_sql_streaming.test_suites-ReadTopicWithMetadataNestedDeep-default.txt_/plan.json"
111+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowPercentile-default.txt_/plan.json"
112112
}
113113
},
114-
"test_sql_streaming.test[suites-ReadTopicWithMetadataWithFilter-default.txt]": {
114+
"test_sql_streaming.test[hopping_window-GroupByHoppingWindowTimeExtractorUnusedColumns-default.txt]": {
115115
"Ast": {
116-
"uri": "file://test_sql_streaming.test_suites-ReadTopicWithMetadataWithFilter-default.txt_/ast.txt"
116+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowTimeExtractorUnusedColumns-default.txt_/ast.txt"
117117
},
118118
"Plan": {
119-
"uri": "file://test_sql_streaming.test_suites-ReadTopicWithMetadataWithFilter-default.txt_/plan.json"
119+
"uri": "file://test_sql_streaming.test_hopping_window-GroupByHoppingWindowTimeExtractorUnusedColumns-default.txt_/plan.json"
120120
}
121121
},
122-
"test_sql_streaming.test[suites-ReadTopicWithSchema-default.txt]": {
122+
"test_sql_streaming.test[pq-ReadTopic-default.txt]": {
123123
"Ast": {
124-
"uri": "file://test_sql_streaming.test_suites-ReadTopicWithSchema-default.txt_/ast.txt"
124+
"uri": "file://test_sql_streaming.test_pq-ReadTopic-default.txt_/ast.txt"
125125
},
126126
"Plan": {
127-
"uri": "file://test_sql_streaming.test_suites-ReadTopicWithSchema-default.txt_/plan.json"
127+
"uri": "file://test_sql_streaming.test_pq-ReadTopic-default.txt_/plan.json"
128128
}
129129
},
130-
"test_sql_streaming.test[suites-ReadTwoTopics-default.txt]": {
130+
"test_sql_streaming.test[pq-ReadTopicWithMetadata-default.txt]": {
131131
"Ast": {
132-
"uri": "file://test_sql_streaming.test_suites-ReadTwoTopics-default.txt_/ast.txt"
132+
"uri": "file://test_sql_streaming.test_pq-ReadTopicWithMetadata-default.txt_/ast.txt"
133133
},
134134
"Plan": {
135-
"uri": "file://test_sql_streaming.test_suites-ReadTwoTopics-default.txt_/plan.json"
135+
"uri": "file://test_sql_streaming.test_pq-ReadTopicWithMetadata-default.txt_/plan.json"
136136
}
137137
},
138-
"test_sql_streaming.test[suites-ReadWriteSameTopic-default.txt]": {
138+
"test_sql_streaming.test[pq-ReadTopicWithMetadataInsideFilter-default.txt]": {
139139
"Ast": {
140-
"uri": "file://test_sql_streaming.test_suites-ReadWriteSameTopic-default.txt_/ast.txt"
140+
"uri": "file://test_sql_streaming.test_pq-ReadTopicWithMetadataInsideFilter-default.txt_/ast.txt"
141141
},
142142
"Plan": {
143-
"uri": "file://test_sql_streaming.test_suites-ReadWriteSameTopic-default.txt_/plan.json"
143+
"uri": "file://test_sql_streaming.test_pq-ReadTopicWithMetadataInsideFilter-default.txt_/plan.json"
144144
}
145145
},
146-
"test_sql_streaming.test[suites-ReadWriteTopic-default.txt]": {
146+
"test_sql_streaming.test[pq-ReadTopicWithMetadataNestedDeep-default.txt]": {
147147
"Ast": {
148-
"uri": "file://test_sql_streaming.test_suites-ReadWriteTopic-default.txt_/ast.txt"
148+
"uri": "file://test_sql_streaming.test_pq-ReadTopicWithMetadataNestedDeep-default.txt_/ast.txt"
149149
},
150150
"Plan": {
151-
"uri": "file://test_sql_streaming.test_suites-ReadWriteTopic-default.txt_/plan.json"
151+
"uri": "file://test_sql_streaming.test_pq-ReadTopicWithMetadataNestedDeep-default.txt_/plan.json"
152152
}
153153
},
154-
"test_sql_streaming.test[suites-ReadWriteTopicWithSchema-default.txt]": {
154+
"test_sql_streaming.test[pq-ReadTopicWithMetadataWithFilter-default.txt]": {
155155
"Ast": {
156-
"uri": "file://test_sql_streaming.test_suites-ReadWriteTopicWithSchema-default.txt_/ast.txt"
156+
"uri": "file://test_sql_streaming.test_pq-ReadTopicWithMetadataWithFilter-default.txt_/ast.txt"
157157
},
158158
"Plan": {
159-
"uri": "file://test_sql_streaming.test_suites-ReadWriteTopicWithSchema-default.txt_/plan.json"
159+
"uri": "file://test_sql_streaming.test_pq-ReadTopicWithMetadataWithFilter-default.txt_/plan.json"
160160
}
161161
},
162-
"test_sql_streaming.test[suites-WriteTwoTopics-default.txt]": {
162+
"test_sql_streaming.test[pq-ReadTopicWithSchema-default.txt]": {
163163
"Ast": {
164-
"uri": "file://test_sql_streaming.test_suites-WriteTwoTopics-default.txt_/ast.txt"
164+
"uri": "file://test_sql_streaming.test_pq-ReadTopicWithSchema-default.txt_/ast.txt"
165165
},
166166
"Plan": {
167-
"uri": "file://test_sql_streaming.test_suites-WriteTwoTopics-default.txt_/plan.json"
167+
"uri": "file://test_sql_streaming.test_pq-ReadTopicWithSchema-default.txt_/plan.json"
168+
}
169+
},
170+
"test_sql_streaming.test[pq-ReadTwoTopics-default.txt]": {
171+
"Ast": {
172+
"uri": "file://test_sql_streaming.test_pq-ReadTwoTopics-default.txt_/ast.txt"
173+
},
174+
"Plan": {
175+
"uri": "file://test_sql_streaming.test_pq-ReadTwoTopics-default.txt_/plan.json"
176+
}
177+
},
178+
"test_sql_streaming.test[pq-ReadWriteSameTopic-default.txt]": {
179+
"Ast": {
180+
"uri": "file://test_sql_streaming.test_pq-ReadWriteSameTopic-default.txt_/ast.txt"
181+
},
182+
"Plan": {
183+
"uri": "file://test_sql_streaming.test_pq-ReadWriteSameTopic-default.txt_/plan.json"
184+
}
185+
},
186+
"test_sql_streaming.test[pq-ReadWriteTopic-default.txt]": {
187+
"Ast": {
188+
"uri": "file://test_sql_streaming.test_pq-ReadWriteTopic-default.txt_/ast.txt"
189+
},
190+
"Plan": {
191+
"uri": "file://test_sql_streaming.test_pq-ReadWriteTopic-default.txt_/plan.json"
192+
}
193+
},
194+
"test_sql_streaming.test[pq-ReadWriteTopicWithSchema-default.txt]": {
195+
"Ast": {
196+
"uri": "file://test_sql_streaming.test_pq-ReadWriteTopicWithSchema-default.txt_/ast.txt"
197+
},
198+
"Plan": {
199+
"uri": "file://test_sql_streaming.test_pq-ReadWriteTopicWithSchema-default.txt_/plan.json"
200+
}
201+
},
202+
"test_sql_streaming.test[pq-WriteTwoTopics-default.txt]": {
203+
"Ast": {
204+
"uri": "file://test_sql_streaming.test_pq-WriteTwoTopics-default.txt_/ast.txt"
205+
},
206+
"Plan": {
207+
"uri": "file://test_sql_streaming.test_pq-WriteTwoTopics-default.txt_/plan.json"
208+
}
209+
},
210+
"test_sql_streaming.test[solomon-ReadTopicGroupWriteToSolomon-default.txt]": {
211+
"Ast": {
212+
"uri": "file://test_sql_streaming.test_solomon-ReadTopicGroupWriteToSolomon-default.txt_/ast.txt"
213+
},
214+
"Plan": {
215+
"uri": "file://test_sql_streaming.test_solomon-ReadTopicGroupWriteToSolomon-default.txt_/plan.json"
216+
}
217+
},
218+
"test_sql_streaming.test[watermarks-watermarks-default.txt]": {
219+
"Ast": {
220+
"uri": "file://test_sql_streaming.test_watermarks-watermarks-default.txt_/ast.txt"
221+
},
222+
"Plan": {
223+
"uri": "file://test_sql_streaming.test_watermarks-watermarks-default.txt_/plan.json"
168224
}
169225
}
170226
}

‎ydb/tests/fq/streaming_optimize/canondata/test_sql_streaming.test_suites-GroupByHop-default.txt_/ast.txt‎ renamed to ‎ydb/tests/fq/streaming_optimize/canondata/test_sql_streaming.test_hop-GroupByHop-default.txt_/ast.txt‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@
6868
(let $69 (CallableType '() '((OptionalType (DataType 'Timestamp))) $68))
6969
(let $70 (Udf '"DateTime2.FromMilliseconds" (Void) (VoidType) '"" $69 (VoidType) '"" '('('"blocks") $16)))
7070
(return (Apply $70 (Convert $67 $23)))
71-
))))) (Interval '5000) $62 $62 'true (lambda '($71) (AsStruct '('Sum0 (Member $71 '"v")))) (lambda '($72 $73) (AsStruct '('Sum0 (AggrAdd (Member $72 '"v") (Member $73 'Sum0))))) $63 $63 (lambda '($75 $76) (AsStruct '('Sum0 (AggrAdd (Member $75 'Sum0) (Member $76 'Sum0))))) (lambda '($77 $78 $79) (AsStruct '('Sum0 (Member $78 'Sum0)) '('"_yql_time" $79) '('"k" $77))) '0))
71+
))))) (Interval '5000) $62 $62 'true (lambda '($71) (AsStruct '('Sum0 (Member $71 '"v")))) (lambda '($72 $73) (AsStruct '('Sum0 (AggrAdd (Member $72 '"v") (Member $73 'Sum0))))) $63 $63 (lambda '($75 $76) (AsStruct '('Sum0 (AggrAdd (Member $75 'Sum0) (Member $76 'Sum0))))) (lambda '($77 $78 $79) (AsStruct '('Sum0 (Member $78 'Sum0)) '('"_yql_time" $79) '('"k" $77))) '0 '"_yql_time"))
7272
(return (FlatMap (ExtractMembers $64 '('Sum0 '"k")) (lambda '($80) (block '(
7373
(let $81 (Udf '"Yson2.SerializeText" (Void) (VoidType) '"" $20 (VoidType) '"" $17))
7474
(let $82 (StructType '('"k" $21) '('"sum" $21)))

‎ydb/tests/fq/streaming_optimize/canondata/test_sql_streaming.test_suites-GroupByHop-default.txt_/plan.json‎ renamed to ‎ydb/tests/fq/streaming_optimize/canondata/test_sql_streaming.test_hop-GroupByHop-default.txt_/plan.json‎

File renamed without changes.

‎ydb/tests/fq/streaming_optimize/canondata/test_sql_streaming.test_suites-GroupByHopByStringKey-default.txt_/ast.txt‎ renamed to ‎ydb/tests/fq/streaming_optimize/canondata/test_sql_streaming.test_hop-GroupByHopByStringKey-default.txt_/ast.txt‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@
7575
(let $72 (CallableType '() '((OptionalType (DataType 'Timestamp))) $71))
7676
(let $73 (Udf '"DateTime2.FromMilliseconds" (Void) (VoidType) '"" $72 (VoidType) '"" '('('"blocks") $16)))
7777
(return (Apply $73 (Convert $70 $23)))
78-
))))) (Interval '5000) $65 $65 'true (lambda '($74) (AsStruct '('Sum0 (Member $74 '"v")))) (lambda '($75 $76) (AsStruct '('Sum0 (AggrAdd (Member $75 '"v") (Member $76 'Sum0))))) $66 $66 (lambda '($78 $79) (AsStruct '('Sum0 (AggrAdd (Member $78 'Sum0) (Member $79 'Sum0))))) (lambda '($80 $81 $82) (AsStruct '('Sum0 (Member $81 'Sum0)) '('"_yql_time" $82) '('"k" $80))) '0))
78+
))))) (Interval '5000) $65 $65 'true (lambda '($74) (AsStruct '('Sum0 (Member $74 '"v")))) (lambda '($75 $76) (AsStruct '('Sum0 (AggrAdd (Member $75 '"v") (Member $76 'Sum0))))) $66 $66 (lambda '($78 $79) (AsStruct '('Sum0 (AggrAdd (Member $78 'Sum0) (Member $79 'Sum0))))) (lambda '($80 $81 $82) (AsStruct '('Sum0 (Member $81 'Sum0)) '('"_yql_time" $82) '('"k" $80))) '0 '"_yql_time"))
7979
(return (FlatMap (ExtractMembers $67 '('Sum0 '"k")) (lambda '($83) (block '(
8080
(let $84 (Udf '"Yson2.SerializeText" (Void) (VoidType) '"" $20 (VoidType) '"" $17))
8181
(let $85 (StructType '('"k" $21) '('"sum" $25)))

‎ydb/tests/fq/streaming_optimize/canondata/test_sql_streaming.test_suites-GroupByHopByStringKey-default.txt_/plan.json‎ renamed to ‎ydb/tests/fq/streaming_optimize/canondata/test_sql_streaming.test_hop-GroupByHopByStringKey-default.txt_/plan.json‎

File renamed without changes.

0 commit comments

Comments
 (0)