-
-
Notifications
You must be signed in to change notification settings - Fork 56
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
How to stream filtered values ? #48
Comments
This library might not be the best tool for the job. Now, if you still want to implement something like this, I would do it in a micro-batch fashion:
|
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Imagine I get a stream of messages like below from a incoming socket
Now I want to filter all the messages that satisfies a certain criteria and push it to an outgoing socket in a streaming fashion. Like say stream all messages where
grandslams > 10 and country = "spain"
. While I am aware few ways to implement this I wonder how to do it effectively using this library?The text was updated successfully, but these errors were encountered: