From 37ba07e20d3c5cd69a1a0fa4abc775b066885b2d Mon Sep 17 00:00:00 2001 From: Martin Tzvetanov Grigorov Date: Fri, 25 Nov 2022 11:40:40 +0200 Subject: [PATCH] Use limit() function instead of show_limit() in the first example Signed-off-by: Martin Tzvetanov Grigorov --- docs/source/user-guide/example-usage.md | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/docs/source/user-guide/example-usage.md b/docs/source/user-guide/example-usage.md index 32b1122abc03..4606aa974756 100644 --- a/docs/source/user-guide/example-usage.md +++ b/docs/source/user-guide/example-usage.md @@ -62,10 +62,11 @@ async fn main() -> datafusion::error::Result<()> { let df = ctx.read_csv("tests/example.csv", CsvReadOptions::new()).await?; let df = df.filter(col("a").lt_eq(col("b")))? - .aggregate(vec![col("a")], vec![min(col("b"))])?; + .aggregate(vec![col("a")], vec![min(col("b"))])? + .limit(0, Some(100))?; // execute and print results - df.show_limit(100).await?; + df.show().await?; Ok(()) } ``` @@ -118,10 +119,11 @@ async fn main() -> datafusion::error::Result<()> { let df = ctx.read_csv("tests/capitalized_example.csv", CsvReadOptions::new()).await?; let df = df.filter(col("A").lt_eq(col("c")))? - .aggregate(vec![col("A")], vec![min(col("b"))])?; + .aggregate(vec![col("A")], vec![min(col("b"))])? + .limit(0, Some(100))?; // execute and print results - df.show_limit(100).await?; + df.show().await?; Ok(()) } ```