Thanks a lot.
This was very helpful .
Hamza
- Message de réponse -
De : "Eno Thereska"
Pour : "users@kafka.apache.org"
Objet : windowing with the processor api
Date : mer., nov. 2, 2016 19:18
Thanks Matthias, yes, to get window operations, or things like hopping
;t find a place where to define the
>> size of the window and where to precise the time of the advance.
>>
>>
>> Hamza
>>
>> Thanks
>>
>> De : Eno Thereska
>> Envoyé : mardi 1 novembre 2016 22:44:47 À
>> : users@kafka.apache.org Objet : Re:
De : Eno Thereska
> Envoyé : mardi 1 novembre 2016 22:44:47 À
> : users@kafka.apache.org Objet : Re: windowing with the processor
> api
>
> Hi Hamza,
>
> Are you getting a particular error? Here is an example :
>
> Stores.create("window-store") .with
: Re: windowing with the processor api
Hi Hamza,
Are you getting a particular error? Here is an example :
Stores.create("window-store")
.withStringKeys()
.withStringValues()
.persistent()
.
Hi Hamza,
Are you getting a particular error? Here is an example :
Stores.create("window-store")
.withStringKeys()
.withStringValues()
.persistent()
.windowed(10, 10, 2, false).build(), "the-pr
Hi,
I would like to know if somebody has an idea how to define the size of the
window in the processor api.
I've been blocked for 6 days looking for a solution.
using :
Stores.create(...).withStringKeys().withStringValues().persistent().windowed(...).build()
I was able to define the retention