Re: emit a single Map<String, T> per window

2016-09-05 Thread Luis Mariano Guerra
On Mon, Sep 5, 2016 at 12:30 PM, Aljoscha Krettek wrote: > Hi, > for this you would have to use a non-parallel window, i.e. something like > stream.windowAll().apply(...). This does not compute per key but > has the drawback that computation does not happen in parallel. If

Re: emit a single Map<String, T> per window

2016-09-02 Thread Luis Mariano Guerra
On Fri, Sep 2, 2016 at 5:24 PM, Aljoscha Krettek wrote: > Hi, > from this I would expect to get as many HashMaps as you have keys. The > winFunction is also executed per-key so it cannot combine the HashMaps of > all keys. > > Does this describe the behavior that you're

Re: emit a single Map<String, T> per window

2016-09-02 Thread Aljoscha Krettek
Hi, from this I would expect to get as many HashMaps as you have keys. The winFunction is also executed per-key so it cannot combine the HashMaps of all keys. Does this describe the behavior that you're seeing? Cheers, Aljoscha On Fri, 2 Sep 2016 at 17:37 Luis Mariano Guerra