streamz
streamz copied to clipboard
python-streamz
Real-time stream processing for python
I just noticed the new release (awesome!) but when I went to look at the list of changes I did not see a changelog. I can go back and create...
It seems that the tests are not included in the conda-forge package. Would it be possible to include them?
It may be nice to see which are the `emit_on` node connections (graph edges) in the visualization. Maybe the not emit_on connections are dashed or wavy? (I think this just...
How do we feel about git hygiene when merging? I personally tend to squash-and-merge PRs, except if git history is particularly clean (this happens very rarely for me). Any thoughts?...
Hi, When I try to use the `timed_window` function with the `asyncio` event loop I get the following error: AttributeError: 'AsyncIOMainLoop' object has no attribute '_running' For example if you...
Given this setup ```python import pandas as pd from streamz.dataframe import DataFrame, Random import streamz.dataframe.holoviews df = pd.DataFrame({'x': [1, 2, 3], 'y': [4.5, 5, 6.5]}, pd.DatetimeIndex([1, 2, 3])) sdf =...
It might be nice to have some speed/performance metrics. [Air Speed Velocity](http://asv.readthedocs.io/en/latest/index.html)?
It may be helpful to have a Gate node, or super node or at least some usage docs/pattern docs. A `gate` node would filter one stream by another stream. This...
Maybe color graph nodes by when the nodes trigger? This could use the message concept in #111, where we pass a message which tracks each call time and node.