Skip to content

Commit f1c99cd

Browse files
committed
clippy
1 parent 2cc2690 commit f1c99cd

1 file changed

Lines changed: 3 additions & 4 deletions

File tree

crates/examples/src/datafusion_incremental_read.rs

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
7272
}
7373

7474
if snapshots.len() < 2 {
75-
println!("\nNeed at least 2 snapshots for incremental read demo.");
75+
println!("Need at least 2 snapshots for incremental read demo.");
7676
println!("Try inserting some data into the table to create more snapshots.");
7777
return Ok(());
7878
}
@@ -82,8 +82,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
8282
let to_snapshot_id = snapshots[snapshots.len() - 1].snapshot_id();
8383

8484
println!(
85-
"\nPerforming incremental read from snapshot {} to {}",
86-
from_snapshot_id, to_snapshot_id
85+
"Performing incremental read from snapshot {from_snapshot_id} to {to_snapshot_id}",
8786
);
8887

8988
// ANCHOR: incremental_read
@@ -118,7 +117,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
118117
ctx.register_table("new_data", Arc::new(provider))?;
119118

120119
let df = ctx.sql("SELECT COUNT(*) as new_rows FROM new_data").await?;
121-
println!("\nNew rows since snapshot {}:", from_snapshot_id);
120+
println!("\nNew rows since snapshot {from_snapshot_id}:");
122121
df.show().await?;
123122
// ANCHOR_END: appends_after
124123

0 commit comments

Comments
 (0)