You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Jon Yeargers <jo...@cedexis.com> on 2017/03/28 17:40:06 UTC

WindowStore and retention

How long does a given value persist in a WindowStore? Does it obey the
'.until()' param of a windowed aggregation/ reduction?

Please say yes.

Re: WindowStore and retention

Posted by "Matthias J. Sax" <ma...@confluent.io>.

Note, it's not based on system/wall-clock time, but based on "stream
time", ie, the internal time progress of your app, that depends on the
timestamps returned by TimestampExtractor.

-Matthias

On 3/28/17 10:55 AM, Matthias J. Sax wrote:
> Yes. :)
> 
> On 3/28/17 10:40 AM, Jon Yeargers wrote:
>> How long does a given value persist in a WindowStore? Does it obey the
>> '.until()' param of a windowed aggregation/ reduction?
>>
>> Please say yes.
>>
>

Re: WindowStore and retention

Posted by "Matthias J. Sax" <ma...@confluent.io>.

Yes. :)

On 3/28/17 10:40 AM, Jon Yeargers wrote:
> How long does a given value persist in a WindowStore? Does it obey the
> '.until()' param of a windowed aggregation/ reduction?
> 
> Please say yes.
>