Re: Streams group final result: EmitStrategy vs Suppressed

2024-04-18 Thread Matthias J. Sax
The main difference is the internal implementation. Semantically, both are equivalent. suppress() uses an in-memory buffer, while `emitStrategy()` does not, but modifies the upstream aggregation operator impl, and waits to send results downstream, and thus, it's RocksDB based. -Matthias

Re: Streams group final result: EmitStrategy vs Suppressed

2024-04-15 Thread Ayoub
Hello, *[Not sure if my email went through as I was not subscribed to this mailing list. Here is my original email]* I found that there are two ways to send only the final result of a windowed groupBy, either using Suppressed

Streams group final result: EmitStrategy vs Suppressed

2024-04-15 Thread Ayoub
Hello, I found that there are two ways to send only the final result of a windowed groupBy, either using Suppressed .untilWindowCloses on the final KTable or