kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hamza HACHANI <hamza.hach...@supcom.tn>
Subject RE: windowing with the processor api
Date Wed, 02 Nov 2016 10:49:23 GMT
Hi Eno,


What I want to say is that i don'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 <eno.thereska@gmail.com>
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")
                          .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
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message