This PR changes the Bytewax syntax to match v0.18 and updates the input source to move to using a built-in polling input mechanism. In addition, it uses branching capabilities to split out the stream into a comment and story stream. It also points to how you can use the Grafana proton data source to query the stream.
This PR changes the Bytewax syntax to match v0.18 and updates the input source to move to using a built-in polling input mechanism. In addition, it uses branching capabilities to split out the stream into a comment and story stream. It also points to how you can use the Grafana proton data source to query the stream.