menziess

4 ms·

1. 1.▲
   by menziess 2y ago

   Compared to Bytewax, Slipstream puts the emphasis on freedom, at the cost of having to implement certain features yourself. This freedom let's you do things that other libraries may not offer within the bounds of their API. For instanc
2. 2.▲
   by menziess 2y ago

   Thanks! This example uses nearby-joins (based on event time): https://slipstream.readthedocs.io/en/1.0.1/cookbook.html#joi... . I hope I get your question right, but if you're joining on a fixed key, the solut
3. 3.▲
   by menziess 2y ago

   The link leads to the readthedocs. The library can be used to parallelize data processing. `AsyncIterables` can be used a data sources, and any `Callable` can be used as a sink. RocksDB is used to preserve state. Checkpoints are used to det
4. 4.▲
   by menziess 2y ago

   Code: https://github.com/Menziess/slipstream-async
5. 5.▲
   Show HN: Slipstream – A Python library for stateful stream processing(slipstream.readthedocs.io)

   32 points by menziess 2y ago|6 comments