Global window keyBy

2018-02-04 Thread miki haiat
Im using trigger and a guid in order to key stream . I have some problem to understand how to clear the window . - FIRE_AND_PURGE in trigger will remove the keyd data only ? if fire and purge is removing all the data then i need to implement it more like this example https://github.

Re: Global window keyBy

2018-02-05 Thread Piotr Nowojski
Hi, FIRE_AND_PURGE triggers `org.apache.flink.api.common.state.State#clear()` call and it "Removes the value mapped under the current key.”. So other keys should remain unmodified. I hope this solves your problem/question? Piotrek > On 4 Feb 2018, at 15:39, miki haiat wrote: > > Im using t

Fwd: Global window keyBy

2018-02-05 Thread miki haiat
yes . another question is how can i clear non trigger events after a period of time. is thire a way to configure some "timeout " thanks, allot . On Mon, Feb 5, 2018 at 10:40 AM, Piotr Nowojski wrote: > Hi, > > FIRE_AND_PURGE triggers `org.apache.flink.api.common.state.State#clear()` > call a