Releases: streamlet-dev/tributary
Releases · streamlet-dev/tributary
Release v0.2.1
Release v0.2.0
First v0.2.0 release, a lot of improvements and some breaking api changes
Release v0.1.5
Adds queue in/out for streaming
Release v0.1.4
Restore a few missing top level exports
Release v0.1.3
- Postgres streaming nodes
- added automatic differentiation to lazy and streaming nodes
Release v0.1.2
- tests for output streaming (thanks @Ferev @maxhhelman !)
- kafka consumer extra kwargs to allow configuration of librdkafka (e.g. for kerberos credentials)
- swap web socket for aiohttp to allow http-proxied websockets
- implemented
FixedMap
node for streaming as the opposite of reduce. dynamic mapping not possible since graph state can't currently be mutated on the fly.
Release v0.1.1
Lots of bugfixes and enhancements to streaming
- Bugfix for Kafka sink
- Bugfix for HTTP source when infinite repeat is desired
- Implemented bit shift operators for better node piping
- Stream markers converted to singletons to avoid reallocating classes (needs further work)
- added
EMA
andSMA
rolling operations for streaming - Added
reducer
arg toReduce
streaming node for consolidating streams - some miscellaneous graph optimizations
Release v0.1.0
lots of enhancements to lazy
Release v0.0.9
Last release before v0.1.0!
Bugfixes for symbolic -> streaming
More numpy integration
Release v0.0.7
- Completely rewritten the streaming api to fix some fundamental bugs
- Reworking lazy stuff
- tons of bug fixes and enhancements