Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

readers: Implement observe reader support #92

Merged
merged 3 commits into from Mar 2, 2022
Merged

Conversation

Xuanwo
Copy link
Member

@Xuanwo Xuanwo commented Mar 2, 2022

Signed-off-by: Xuanwo github@xuanwo.io

I hereby agree to the terms of the CLA available at: https://databend.rs/dev/policies/cla/

Summary

Address #84

Signed-off-by: Xuanwo <github@xuanwo.io>
@Xuanwo Xuanwo linked an issue Mar 2, 2022 that may be closed by this pull request
@Xuanwo
Copy link
Member Author

Xuanwo commented Mar 2, 2022

@BohuTANG This PR will make it possible to calculate the read cost inside the reader.

And we are archiving it in a much better way: we can calculate the cost for pending, for reading. We can even calculate the averaging reading speed based on ReadEvent::Read(n).

@Xuanwo Xuanwo merged commit 00b1b2d into apache:main Mar 2, 2022
@Xuanwo Xuanwo deleted the observer branch June 13, 2022 05:03
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Allow CallbackReader to calculate the read cost
1 participant