Skip to content
This repository has been archived by the owner on Feb 18, 2024. It is now read-only.

Commit

Permalink
Fixed example
Browse files Browse the repository at this point in the history
  • Loading branch information
jorgecarleitao committed Feb 6, 2022
1 parent a282f6e commit 8539846
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion examples/parquet_read_async.rs
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ async fn main() -> Result<()> {
// A row group is consumed in two steps: the first step is to read the (compressed)
// columns into memory, which is IO-bounded.
let column_chunks =
read::read_columns_async(factory, row_group, schema.fields.clone(), None).await?;
read::read_columns_many_async(factory, row_group, schema.fields.clone(), None).await?;

// the second step is to iterate over the columns in chunks.
// this operation is CPU-bounded and should be sent to a separate thread pool (e.g. `tokio_rayon`) to not block
Expand Down

0 comments on commit 8539846

Please sign in to comment.