MCPcopy Create free account
hub / github.com/apache/datafusion / count_aggregated

Function count_aggregated

datafusion/core/tests/sql/aggregates/basic.rs:89–104  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

87
88#[tokio::test]
89async fn count_aggregated() -> Result<()> {
90 let results =
91 execute_with_partition("SELECT c1, count(c2) FROM test GROUP BY c1", 4).await?;
92
93 assert_snapshot!(batches_to_sort_string(&results), @r"
94 +----+----------------+
95 | c1 | count(test.c2) |
96 +----+----------------+
97 | 0 | 10 |
98 | 1 | 10 |
99 | 2 | 10 |
100 | 3 | 10 |
101 +----+----------------+
102 ");
103 Ok(())
104}
105
106#[tokio::test]
107async fn count_aggregated_cube() -> Result<()> {

Callers

nothing calls this directly

Calls 1

execute_with_partitionFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…