Aggregates and user defined time based window functions
Combining aggregates, stateful and stateless window functions is a powerful mix to provide group-by analytics over a stream of events
This example computes basic aggregates and a mix of stateless and stateful analytic functions or time base sliding windows.
Use case configuration
File: app-aggregatesAndEMA.env
Pipeline configuration
This pipeline configures a sliding window of 2.5 second with a 500ms slide which computes aggregates and three window listener functions, all using the same event window.
Last updated