Re : windowing with the processor api

2016-11-02 Thread Hamza HACHANI
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

Re: windowing with the processor api

2016-11-02 Thread Eno Thereska
;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:

Re: windowing with the processor api

2016-11-02 Thread Matthias J. Sax
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

2016-11-02 Thread Hamza HACHANI
: 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() .

Re: windowing with the processor api

2016-11-02 Thread Eno Thereska
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

windowing with the processor api

2016-11-02 Thread Hamza HACHANI
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