Heres a short blurb for Streams API & windowing enhancements. 1. Streams API
A typed API for expressing streaming computations more easily using functional style operations. It builds on top of the Storm's core spouts and bolt APIs and automatically fuses multiple operations together to optimize the pipeline. For more details and examples see - https://github.com/apache/storm/blob/master/docs/Stream-API.md 2. Windowing enhancements Storm can save/restore the window state to the configured state backend so that larger continuous windows can be supported. The window boundaries can now be accessed via the APIs. For more details see - https://github.com/apache/storm/blob/master/docs/Windowing.md#stateful-windowing Thanks, Arun
