Documentation: Windowing

Sliding and Tumbling Windows explained

Windowing allows you to process a snapshot of streaming data.  These two posts explain sliding and tumbling windows in SPL and are a great way...

Hourly Moving Average — Streams makes it simple

In a recent discussion around using Streams, the following use case was considered problematic for an existing system. Given a set of devices that produce...

C++ Primitive Operator with Sliding Window

Illustrates how to create a non-generic C++ primitive operator which uses a sliding window. The code is header-only and uses the pimpl idiom to...

Example: Analyzing Weather Data using Windowing

My goal with this article is to provide a working example of how to build a Streams Application. In this example, I will be building...