@@ -55,10 +55,10 @@ fn test_pushdown_into_scan() {
5555 OptimizationTest:
5656 input:
5757 - FilterExec: a@0 = foo
58- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
58+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
5959 output:
6060 Ok:
61- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
61+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
6262 "
6363 ) ;
6464}
@@ -81,11 +81,11 @@ fn test_pushdown_into_scan_with_config_options() {
8181 OptimizationTest:
8282 input:
8383 - FilterExec: a@0 = foo
84- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
84+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
8585 output:
8686 Ok:
8787 - FilterExec: a@0 = foo
88- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
88+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
8989 "
9090 ) ;
9191
@@ -100,10 +100,10 @@ fn test_pushdown_into_scan_with_config_options() {
100100 OptimizationTest:
101101 input:
102102 - FilterExec: a@0 = foo
103- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
103+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
104104 output:
105105 Ok:
106- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
106+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
107107 "
108108 ) ;
109109}
@@ -124,10 +124,10 @@ fn test_filter_collapse() {
124124 input:
125125 - FilterExec: b@1 = bar
126126 - FilterExec: a@0 = foo
127- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
127+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
128128 output:
129129 Ok:
130- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo AND b@1 = bar
130+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo AND b@1 = bar
131131 "
132132 ) ;
133133}
@@ -151,11 +151,11 @@ fn test_filter_with_projection() {
151151 OptimizationTest:
152152 input:
153153 - FilterExec: a@0 = foo, projection=[b@1, a@0]
154- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
154+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
155155 output:
156156 Ok:
157157 - ProjectionExec: expr=[b@1 as b, a@0 as a]
158- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
158+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
159159 " ,
160160 ) ;
161161
@@ -174,11 +174,11 @@ fn test_filter_with_projection() {
174174 OptimizationTest:
175175 input:
176176 - FilterExec: a@0 = foo, projection=[b@1]
177- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
177+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
178178 output:
179179 Ok:
180180 - ProjectionExec: expr=[b@1 as b]
181- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
181+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
182182 "
183183 ) ;
184184}
@@ -206,12 +206,12 @@ fn test_push_down_through_transparent_nodes() {
206206 - RepartitionExec: partitioning=RoundRobinBatch(1), input_partitions=1
207207 - FilterExec: a@0 = foo
208208 - CoalesceBatchesExec: target_batch_size=1
209- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
209+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
210210 output:
211211 Ok:
212212 - RepartitionExec: partitioning=RoundRobinBatch(1), input_partitions=1
213213 - CoalesceBatchesExec: target_batch_size=1
214- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo AND b@1 = bar
214+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo AND b@1 = bar
215215 "
216216 ) ;
217217}
@@ -271,14 +271,14 @@ fn test_no_pushdown_through_aggregates() {
271271 - AggregateExec: mode=Final, gby=[a@0 as a, b@1 as b], aggr=[cnt], ordering_mode=PartiallySorted([0])
272272 - FilterExec: a@0 = foo
273273 - CoalesceBatchesExec: target_batch_size=10
274- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
274+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
275275 output:
276276 Ok:
277277 - FilterExec: b@1 = bar
278278 - CoalesceBatchesExec: target_batch_size=100
279279 - AggregateExec: mode=Final, gby=[a@0 as a, b@1 as b], aggr=[cnt]
280280 - CoalesceBatchesExec: target_batch_size=10
281- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
281+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
282282 "
283283 ) ;
284284}
@@ -298,11 +298,11 @@ fn test_node_handles_child_pushdown_result() {
298298 OptimizationTest:
299299 input:
300300 - TestInsertExec { inject_filter: true }
301- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
301+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
302302 output:
303303 Ok:
304304 - TestInsertExec { inject_filter: true }
305- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
305+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 = foo
306306 " ,
307307 ) ;
308308
@@ -317,12 +317,12 @@ fn test_node_handles_child_pushdown_result() {
317317 OptimizationTest:
318318 input:
319319 - TestInsertExec { inject_filter: true }
320- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=false
320+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=false
321321 output:
322322 Ok:
323323 - TestInsertExec { inject_filter: false }
324324 - FilterExec: a@0 = foo
325- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=false
325+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=false
326326 " ,
327327 ) ;
328328
@@ -337,11 +337,11 @@ fn test_node_handles_child_pushdown_result() {
337337 OptimizationTest:
338338 input:
339339 - TestInsertExec { inject_filter: false }
340- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=false
340+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=false
341341 output:
342342 Ok:
343343 - TestInsertExec { inject_filter: false }
344- - DataSourceExec: file_groups={1 group: [[test.paqruet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=false
344+ - DataSourceExec: file_groups={1 group: [[test.parquet ]]}, projection=[a, b, c], file_type=test, pushdown_supported=false
345345 " ,
346346 ) ;
347347}
0 commit comments