streamz
streamz copied to clipboard
python-streamz
Real-time stream processing for python
`Streamz.from_textfile` could probably be improved to read from files in a non-blocking fashion, and only emit new data once full lines are written. [Apparently](https://groups.google.com/forum/#!topic/python-tornado/KZl-kJT-8zA) we'll probably need a separate thread...
Hi, I would like to calculate the `.value_counts()` from a pandas dataframe in chunks of n elements and output the aggregated result. For example, I have 1000 elements. Calculate the...
Im trying to plot a simple chart with streamz + panel in jupyter lab but there seems to be an issue at the end: there is an extra line that...
Added filter class to dask.py and four tests associated with it.
I'm curious as to why `sdf.groupby([.., ..]).min()/max()` aren't supported. I see that `sum`, `mean`, `std`, `var`, etc. are. Any complexity of the issue I might be missing?
https://streamz.readthedocs.io/en/latest/dask.html My environment: WSL / Debian on Windows 10 18362.778 Python 3.7.3 streamz 0.5.3 dask 2.15.0 Running the "Sequential Execution" example: ``` $ python stream_test.py distributed.comm.tcp - WARNING - Could...
Hey, thanks for this library, it's great. I'm building an ML application that is learning in an online way. So, it's constantly acquiring new feature rows, but also having to...
Is it possible to stream GeoDataFrames, e.g. to track object movement? I followed the https://hvplot.holoviz.org/user_guide/Streaming.html examples but failed to modify them to work for GeoDataFrames / GeoViews.
I have a few projects that require `~=0.5.0` of streamz. Today I got upgraded to `0.5.3` and found that it is aggressively not backwards compatible as this new version assumes...
