fix

Signed-off-by: jayzhan211 <[email protected]>
apache · Jun 6, 2024 · 3754f58 · 3754f58
1 parent c689980
commit 3754f58
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git 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
@@ -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
@@ -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))?;