- DSL modules for Spouts and Bolts
- sync dispatch and disruptor-based self-hosting
- bugfixes in nested streams support
bolt1<'a> --> bolt2 |> Shuffle.on Stream
syntax support
- support for nested and generic streams
- netstandard 2.0 release
- Fixing spout timeout when running as a shelled component
- Reverting the debug logging in Hosting modules
- Re-introducing async Next handling in the spout
- Make unanchored emit available to bolt's Activate/Deactive
- Reverting spout to non-async, adding Activate/Deactive support for bolts
- Conditional spout inputs logging
- Concurrent spout Next, self-host optimizations
- Self-hosting: seed the id generator
- Self-hosting tracks split streams correctly
- Added experimenal self-hosting, breaking changes in Management API
- Added support for
activate
and deactivate
messages introduced in Storm 1.1.0
- Extending DSL for components defined outside of
topology
CE
- and adding the ability to combine (++) multiple topologies
- Adding support for streaming of DU fields
- Adding auto-nacking bolt and corresponding "terminator" component
- Rebuilt with Google.Protobuf beta3
- Removed thrift multilang IO
- Added support for system streams (w/o explicit edges)
- Added support for Nullable fields
- Nuget dependencies, really fixed
- Stream name override via DisplayName attr
- Storm-side serializer bundling added