Fluvio SmartModules support the following in-line data analytics patterns:
An Aggregate SmartModule ability to create a feedback loop, by providing a Accumulator Record that is persistent per stream. Each event may modify the Accumulator, and the changes will be available for next input to use.
The value of the Accumulator Record is also returned after each input.
For example, if you’re trying to Sum up stream of numbers, you would add each input value to the current value of the Accumulator Record.
Checkout aggregate section for an example.
