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

Function test_array_agg

datafusion/core/tests/dataframe/mod.rs:5387–5406  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

5385
5386#[tokio::test]
5387async fn test_array_agg() -> Result<()> {
5388 let df = create_test_table("test")
5389 .await?
5390 .aggregate(vec![], vec![array_agg(col("a"))])?;
5391
5392 let results = df.collect().await?;
5393
5394 assert_snapshot!(
5395 batches_to_string(&results),
5396 @r"
5397 +-------------------------------------+
5398 | array_agg(test.a) |
5399 +-------------------------------------+
5400 | [abcDEF, abc123, CBAdef, 123AbcDef] |
5401 +-------------------------------------+
5402 "
5403 );
5404
5405 Ok(())
5406}
5407
5408#[tokio::test]
5409async fn test_dataframe_placeholder_missing_param_values() -> Result<()> {

Callers

nothing calls this directly

Calls 3

collectMethod · 0.80
create_test_tableFunction · 0.70
aggregateMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…