Re : windowing with the processor api

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

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