This library provides methods and collection wrappers that perform time windowing transformations of IEnumerable collections.
Nuget: Install-Package Scaleout.Streaming.TimeWindowing
Documentation: https://scaleoutsoftware.github.io/TimeWindowingDotNet/
This time windowing library was written by ScaleOut Software to support stateful stream processing in its StreamServer product, which allows events to be processed directly on the distributed in-memory data grid that manages state.
Events associated with persisted state are typically stored as a serialized collection of elements, so this library is designed to be used with ordered IEnumerable collections. It is targeted to developers who prefer straightforward LINQ-style operators and would rather not convert collections to Rx observables to perform windowing.
This library is open source and has no dependencies on other ScaleOut Software products.
License: Apache 2