Skip to content

Commit 7b7c405

Browse files
gabotechsgabotechs
committed
Fix tests
1 parent aca7b83 commit 7b7c405

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

‎src/physical_optimizer.rs‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -227,12 +227,12 @@ mod tests {
227227
│partitions [out:4 <-- in:4 ] ProjectionExec: expr=[count(Int64(1))@1 as count(*), RainToday@0 as RainToday, count(Int64(1))@1 as count(Int64(1))]
228228
│partitions [out:4 <-- in:4 ] AggregateExec: mode=FinalPartitioned, gby=[RainToday@0 as RainToday], aggr=[count(Int64(1))]
229229
│partitions [out:4 <-- in:4 ] CoalesceBatchesExec: target_batch_size=8192
230-
│partitions [out:4 ] ArrowFlightReadExec: Stage 2
230+
│partitions [out:4 ] ArrowFlightReadExec: Stage 2
231231
│
232232
└──────────────────────────────────────────────────
233233
┌───── Stage 2 Task: partitions: 0..3,unassigned]
234234
│partitions [out:4 <-- in:4 ] RepartitionExec: partitioning=Hash([RainToday@0], 4), input_partitions=4
235-
│partitions [out:4 ] ArrowFlightReadExec: Stage 1
235+
│partitions [out:4 ] ArrowFlightReadExec: Stage 1
236236
│
237237
└──────────────────────────────────────────────────
238238
┌───── Stage 1 Task: partitions: 0..3,unassigned]
@@ -257,13 +257,13 @@ mod tests {
257257
│partitions [out:4 <-- in:4 ] ProjectionExec: expr=[count(Int64(1))@1 as count(*), RainToday@0 as RainToday, count(Int64(1))@1 as count(Int64(1))]
258258
│partitions [out:4 <-- in:4 ] AggregateExec: mode=FinalPartitioned, gby=[RainToday@0 as RainToday], aggr=[count(Int64(1))]
259259
│partitions [out:4 <-- in:4 ] CoalesceBatchesExec: target_batch_size=8192
260-
│partitions [out:4 ] ArrowFlightReadExec: Stage 2
260+
│partitions [out:4 ] ArrowFlightReadExec: Stage 2
261261
│
262262
└──────────────────────────────────────────────────
263263
┌───── Stage 2 Task: partitions: 0,1,unassigned],Task: partitions: 2,3,unassigned]
264264
│partitions [out:4 <-- in:2 ] RepartitionExec: partitioning=Hash([RainToday@0], 4), input_partitions=2
265265
│partitions [out:2 <-- in:4 ] PartitionIsolatorExec [providing upto 2 partitions]
266-
│partitions [out:4 ] ArrowFlightReadExec: Stage 1
266+
│partitions [out:4 ] ArrowFlightReadExec: Stage 1
267267
│
268268
└──────────────────────────────────────────────────
269269
┌───── Stage 1 Task: partitions: 0,1,unassigned],Task: partitions: 2,3,unassigned]
@@ -326,19 +326,19 @@ mod tests {
326326
│partitions [out:4 <-- in:4 ] ProjectionExec: expr=[avg(weather.MinTemp)@1 as MinTemp, RainTomorrow@0 as RainTomorrow]
327327
│partitions [out:4 <-- in:4 ] AggregateExec: mode=FinalPartitioned, gby=[RainTomorrow@0 as RainTomorrow], aggr=[avg(weather.MinTemp)]
328328
│partitions [out:4 <-- in:4 ] CoalesceBatchesExec: target_batch_size=8192
329-
│partitions [out:4 ] ArrowFlightReadExec: Stage 2
329+
│partitions [out:4 ] ArrowFlightReadExec: Stage 2
330330
│partitions [out:4 <-- in:4 ] ProjectionExec: expr=[avg(weather.MaxTemp)@1 as MaxTemp, RainTomorrow@0 as RainTomorrow]
331331
│partitions [out:4 <-- in:4 ] AggregateExec: mode=FinalPartitioned, gby=[RainTomorrow@0 as RainTomorrow], aggr=[avg(weather.MaxTemp)]
332332
│partitions [out:4 <-- in:4 ] CoalesceBatchesExec: target_batch_size=8192
333-
│partitions [out:4 ] ArrowFlightReadExec: Stage 4
333+
│partitions [out:4 ] ArrowFlightReadExec: Stage 4
334334
│
335335
└──────────────────────────────────────────────────
336336
┌───── Stage 2 Task: partitions: 0..3,unassigned]
337337
│partitions [out:4 <-- in:4 ] RepartitionExec: partitioning=Hash([RainTomorrow@0], 4), input_partitions=4
338338
│partitions [out:4 <-- in:4 ] AggregateExec: mode=Partial, gby=[RainTomorrow@1 as RainTomorrow], aggr=[avg(weather.MinTemp)]
339339
│partitions [out:4 <-- in:4 ] CoalesceBatchesExec: target_batch_size=8192
340340
│partitions [out:4 <-- in:4 ] FilterExec: RainToday@1 = yes, projection=[MinTemp@0, RainTomorrow@2]
341-
│partitions [out:4 ] ArrowFlightReadExec: Stage 1
341+
│partitions [out:4 ] ArrowFlightReadExec: Stage 1
342342
│
343343
└──────────────────────────────────────────────────
344344
┌───── Stage 1 Task: partitions: 0..3,unassigned]
@@ -352,7 +352,7 @@ mod tests {
352352
│partitions [out:4 <-- in:4 ] AggregateExec: mode=Partial, gby=[RainTomorrow@1 as RainTomorrow], aggr=[avg(weather.MaxTemp)]
353353
│partitions [out:4 <-- in:4 ] CoalesceBatchesExec: target_batch_size=8192
354354
│partitions [out:4 <-- in:4 ] FilterExec: RainToday@1 = no, projection=[MaxTemp@0, RainTomorrow@2]
355-
│partitions [out:4 ] ArrowFlightReadExec: Stage 3
355+
│partitions [out:4 ] ArrowFlightReadExec: Stage 3
356356
│
357357
└──────────────────────────────────────────────────
358358
┌───── Stage 3 Task: partitions: 0..3,unassigned]
@@ -385,12 +385,12 @@ mod tests {
385385
┌───── Stage 3 Task: partitions: 0..3,unassigned]
386386
│partitions [out:4 <-- in:4 ] AggregateExec: mode=FinalPartitioned, gby=[RainToday@0 as RainToday, WindGustDir@1 as WindGustDir], aggr=[]
387387
│partitions [out:4 <-- in:4 ] CoalesceBatchesExec: target_batch_size=8192
388-
│partitions [out:4 ] ArrowFlightReadExec: Stage 2
388+
│partitions [out:4 ] ArrowFlightReadExec: Stage 2
389389
│
390390
└──────────────────────────────────────────────────
391391
┌───── Stage 2 Task: partitions: 0..3,unassigned]
392392
│partitions [out:4 <-- in:4 ] RepartitionExec: partitioning=Hash([RainToday@0, WindGustDir@1], 4), input_partitions=4
393-
│partitions [out:4 ] ArrowFlightReadExec: Stage 1
393+
│partitions [out:4 ] ArrowFlightReadExec: Stage 1
394394
│
395395
└──────────────────────────────────────────────────
396396
┌───── Stage 1 Task: partitions: 0..3,unassigned]

0 commit comments

Comments
 (0)