This repository has been archived by the owner on Feb 18, 2024. It is now read-only.
Added support to read parquet asynchronously #260
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Codecov Report
@@ Coverage Diff @@
## main #260 +/- ##
=======================================
Coverage 77.03% 77.03%
=======================================
Files 241 241
Lines 20446 20446
=======================================
Hits 15750 15750
Misses 4696 4696
Continue to review full report at Codecov.
|
jorgecarleitao
force-pushed
the
async_parquet
branch
from
b5a9c5f
to
93d39fe
Compare
jorgecarleitao
changed the title
jorgecarleitao
force-pushed
the
async_parquet
branch
6 times, most recently
from
a826f27
to
bd077fa
Compare
jorgecarleitao
force-pushed
the
async_parquet
branch
from
cff247a
to
df104cd
Compare
jorgecarleitao
added
enhancement
This was referenced Sep 12, 2021
Sign up for free
to subscribe to this conversation on GitHub.
Already have an account?
Sign in.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
This adds support to read parquet asynchronously.
New APIs
pub async fn read_metadata_async -> Result<FileMetadata>pub async fn get_page_stream -> Result<impl Stream<Item = Result<CompressedDataPage>>pub async fn page_stream_to_array -> Result<Box<dyn Array>>which allow to read the files' metadata and pages into arrow asynchronously (i.e. via
.await). For now this is only implemented for basic types. Following PRs will extend support for the remaining types.This PR also adds an example demonstrating how to use this against s3.