Skip to content

Commit 5d08325

Browse files
jayzhan211alamb
andauthored
Count wildcard alias (#14927)
* fix alias * append the string * window count * add column * fmt * rm todo * fixed partitioned * fix test * update doc * Suggestion to reduce API surface area --------- Co-authored-by: Andrew Lamb <[email protected]>
1 parent c61e7e5 commit 5d08325

File tree

4 files changed

+360
-41
lines changed

4 files changed

+360
-41
lines changed

datafusion/core/tests/dataframe/dataframe_functions.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1145,9 +1145,9 @@ async fn test_count_wildcard() -> Result<()> {
11451145
.build()
11461146
.unwrap();
11471147

1148-
let expected = "Sort: count(Int64(1)) ASC NULLS LAST [count(Int64(1)):Int64]\
1149-
\n Projection: count(Int64(1)) [count(Int64(1)):Int64]\
1150-
\n Aggregate: groupBy=[[test.b]], aggr=[[count(Int64(1))]] [b:UInt32, count(Int64(1)):Int64]\
1148+
let expected = "Sort: count(*) ASC NULLS LAST [count(*):Int64]\
1149+
\n Projection: count(*) [count(*):Int64]\
1150+
\n Aggregate: groupBy=[[test.b]], aggr=[[count(Int64(1)) AS count(*)]] [b:UInt32, count(*):Int64]\
11511151
\n TableScan: test [a:UInt32, b:UInt32, c:UInt32]";
11521152

11531153
let formatted_plan = plan.display_indent_schema().to_string();

0 commit comments

Comments
 (0)