diff --git a/datafusion-examples/examples/advanced_udaf.rs b/datafusion-examples/examples/advanced_udaf.rs index a8f6ec469f50..2c672a18a738 100644 --- a/datafusion-examples/examples/advanced_udaf.rs +++ b/datafusion-examples/examples/advanced_udaf.rs @@ -415,7 +415,7 @@ async fn main() -> Result<()> { let df = ctx.table("t").await?; // perform the aggregation - let df = df.aggregate(vec![], vec![geometric_mean.call(vec![col("a")]).build()])?; + let df = df.aggregate(vec![], vec![geometric_mean.call(vec![col("a")])])?; // note that "a" is f32, not f64. DataFusion coerces it to match the UDAF's signature. diff --git a/datafusion-examples/examples/simple_udaf.rs b/datafusion-examples/examples/simple_udaf.rs index 13856d6e43aa..140fc0d3572d 100644 --- a/datafusion-examples/examples/simple_udaf.rs +++ b/datafusion-examples/examples/simple_udaf.rs @@ -163,7 +163,7 @@ async fn main() -> Result<()> { let df = ctx.table("t").await?; // perform the aggregation - let df = df.aggregate(vec![], vec![geometric_mean.call(vec![col("a")]).build()])?; + let df = df.aggregate(vec![], vec![geometric_mean.call(vec![col("a")])])?; // note that "a" is f32, not f64. DataFusion coerces it to match the UDAF's signature. diff --git a/datafusion-examples/examples/simplify_udaf_expression.rs b/datafusion-examples/examples/simplify_udaf_expression.rs index a199ed2b8091..d2c8c6a86c7c 100644 --- a/datafusion-examples/examples/simplify_udaf_expression.rs +++ b/datafusion-examples/examples/simplify_udaf_expression.rs @@ -167,7 +167,7 @@ async fn main() -> Result<()> { assert_batches_eq!(expected, &result); let df = ctx.table("t").await?; - let df = df.aggregate(vec![], vec![better_avg.call(vec![col("a")]).build()])?; + let df = df.aggregate(vec![], vec![better_avg.call(vec![col("a")])])?; let results = df.collect().await?; let result = as_float64_array(results[0].column(0))?;