Skip to content

Commit

Permalink
features
Browse files Browse the repository at this point in the history
  • Loading branch information
ritchie46 committed Mar 15, 2024
1 parent 8607fd0 commit d21b256
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions crates/polars-io/src/parquet/read_impl.rs
Original file line number Diff line number Diff line change
Expand Up @@ -650,11 +650,12 @@ impl BatchedParquetReader {
self.use_statistics,
self.hive_partition_columns.as_deref(),
),
#[cfg(feature = "async")]
ColumnStore::Fetched(b) => {
// This branch we spawn th decoding and decompression of the bytes on a rayon task.
// This will ensure we don't block the aysnc thread.
// This branch we spawn the decoding and decompression of the bytes on a rayon task.
// This will ensure we don't block the async thread.

// Reconstruct as that makes it a static.
// Reconstruct as that makes it a 'static.
let store = ColumnStore::Fetched(b);
let (tx, rx) = tokio::sync::oneshot::channel();

Expand Down

0 comments on commit d21b256

Please sign in to comment.