@@ -434,13 +434,13 @@ def test_explain(df):
434
434
def test_logical_plan (aggregate_df ):
435
435
plan = aggregate_df .logical_plan ()
436
436
437
- expected = "Projection: test.c1, SUM (test.c2)"
437
+ expected = "Projection: test.c1, sum (test.c2)"
438
438
439
439
assert expected == plan .display ()
440
440
441
441
expected = (
442
- "Projection: test.c1, SUM (test.c2)\n "
443
- " Aggregate: groupBy=[[test.c1]], aggr=[[SUM (test.c2)]]\n "
442
+ "Projection: test.c1, sum (test.c2)\n "
443
+ " Aggregate: groupBy=[[test.c1]], aggr=[[sum (test.c2)]]\n "
444
444
" TableScan: test"
445
445
)
446
446
@@ -450,12 +450,12 @@ def test_logical_plan(aggregate_df):
450
450
def test_optimized_logical_plan (aggregate_df ):
451
451
plan = aggregate_df .optimized_logical_plan ()
452
452
453
- expected = "Aggregate: groupBy=[[test.c1]], aggr=[[SUM (test.c2)]]"
453
+ expected = "Aggregate: groupBy=[[test.c1]], aggr=[[sum (test.c2)]]"
454
454
455
455
assert expected == plan .display ()
456
456
457
457
expected = (
458
- "Aggregate: groupBy=[[test.c1]], aggr=[[SUM (test.c2)]]\n "
458
+ "Aggregate: groupBy=[[test.c1]], aggr=[[sum (test.c2)]]\n "
459
459
" TableScan: test projection=[c1, c2]"
460
460
)
461
461
@@ -466,7 +466,7 @@ def test_execution_plan(aggregate_df):
466
466
plan = aggregate_df .execution_plan ()
467
467
468
468
expected = (
469
- "AggregateExec: mode=FinalPartitioned, gby=[c1@0 as c1], aggr=[SUM (test.c2)]\n " # noqa: E501
469
+ "AggregateExec: mode=FinalPartitioned, gby=[c1@0 as c1], aggr=[sum (test.c2)]\n " # noqa: E501
470
470
)
471
471
472
472
assert expected == plan .display ()
0 commit comments