Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Apply suggestions from code review
Co-authored-by: Vukasin Stefanovic <[email protected]>
  • Loading branch information
alamb and vustef authored Nov 4, 2025
commit db876a944c364ee1b9f773936ad9688deb4a3381
6 changes: 3 additions & 3 deletions parquet/src/arrow/async_reader/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,7 @@ impl ArrowReaderMetadata {
#[doc(hidden)]
/// Newtype (wrapper) used within [`ArrowReaderBuilder`] to distinguish sync readers from async
///
/// Allows sharing the same builder different readers while keeping the same
/// Allows sharing the same builder for different readers while keeping the same
/// ParquetRecordBatchStreamBuilder API
pub struct AsyncReader<T>(T);

Expand Down Expand Up @@ -542,7 +542,7 @@ enum RequestState<T> {
ranges: Vec<Range<u64>>,
/// Future that will resolve (input, requested_ranges)
///
/// Note the future owns the reader while the request it outstanding
/// Note the future owns the reader while the request is outstanding
/// and returns it upon completion
future: BoxFuture<'static, Result<(T, Vec<Bytes>)>>,
},
Expand All @@ -553,7 +553,7 @@ impl<T> RequestState<T>
where
T: AsyncFileReader + Unpin + Send + 'static,
{
// Issue a request to fetch a single range, returining the Outstanding state
// Issue a request to fetch a single range, returning the Outstanding state
fn begin_request(mut input: T, ranges: Vec<Range<u64>>) -> Self {
let ranges_captured = ranges.clone();

Expand Down
Loading