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

Added support for async read of Avro #620

Merged
merged 1 commit into from
Dec 13, 2021
Merged

Added support for async read of Avro #620

merged 1 commit into from
Dec 13, 2021

Conversation

jorgecarleitao
Copy link
Owner

This PR adds support to read Avro asynchronously via AsyncRead + AsyncSeek. As usual, the IO is separated from CPU/blocking code so that we can perform run async / non-blocking code separated from blocking code.

This also adds an example showing how to read an Avro file with Tokio runtime, as well as an entry to the guide about it.

@jorgecarleitao jorgecarleitao added the feature A new feature label Nov 20, 2021
@jorgecarleitao jorgecarleitao force-pushed the async_avro branch 3 times, most recently from 8e15d92 to 7a69e65 Compare November 20, 2021 17:00
@codecov
Copy link

codecov bot commented Nov 20, 2021

Codecov Report

Merging #620 (8bfc2d5) into main (a8c55f9) will increase coverage by 0.15%.
The diff coverage is 87.87%.

Impacted file tree graph

@@            Coverage Diff             @@
##             main     #620      +/-   ##
==========================================
+ Coverage   69.59%   69.74%   +0.15%     
==========================================
  Files         301      303       +2     
  Lines       16779    16818      +39     
==========================================
+ Hits        11677    11730      +53     
+ Misses       5102     5088      -14     
Impacted Files Coverage Δ
src/io/avro/read/deserialize.rs 72.64% <ø> (ø)
src/io/avro/read/schema.rs 52.38% <0.00%> (ø)
src/io/avro/read_async/block.rs 82.75% <82.75%> (ø)
src/io/avro/read_async/utils.rs 85.71% <85.71%> (ø)
src/io/avro/read_async/metadata.rs 95.00% <95.00%> (ø)
src/io/avro/read/block.rs 71.42% <100.00%> (+0.84%) ⬆️
src/io/avro/read/decompress.rs 80.64% <100.00%> (ø)
src/io/avro/read/mod.rs 81.25% <100.00%> (ø)
src/bitmap/utils/slice_iterator.rs 92.53% <0.00%> (+1.49%) ⬆️
src/error.rs 36.36% <0.00%> (+9.09%) ⬆️

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update a8c55f9...8bfc2d5. Read the comment docs.

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
feature A new feature
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant