>>
>> Hamza
>>
>> Thanks
>>
>> De : Eno Thereska
>> Envoyé : mardi 1 novembre 2016 22:44:47 À
>> : users@kafka.apache.org Objet : Re: windowing with the processor
>> api
>>
>> Hi Hamza,
>>
>>
;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