How do I configure an aggregation board in streaming pipeline builder to emit intermediate results after every record?

Ask the Community
,
1

In pipeline builder, I configured the board “Aggregate Over Window” to calculate the rolling average of my value over a 4 hour period. But it looks like it’s only emitting results after the 4 hour window is passed. I want my results after every record, not just after 4 hours.

Image contains notional data

image
image987×588 40 KB

2

You can configure the “Aggregate Over Window” board with an early count trigger set to 1. This will make the board emit results after every record.

Image has notional data:

image
image997×870 56.2 KB