kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Eno Thereska <eno.there...@gmail.com>
Subject Re: windowing with the processor api
Date Wed, 02 Nov 2016 10:44:47 GMT
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-processor")

Thanks
Eno

> On 2 Nov 2016, at 08:19, Hamza HACHANI <hamza.hachani@supcom.tn> wrote:
> 
> 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 time but not the the size of the window.
> 
> Please help me if possible.
> 
> Thanks,
> 
> Hamza


Mime
View raw message