Global window keyBy

[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.com/dataArtisans/flink-training-exercises/blob/master/src/main/java/com/dataartisans/flinktraining/exercises/datastream_java/windows/DrivingSegments.java

Evictor is used in order to clear the data by time stamp  but how can i clear the data  by the key  also ?

thanks ,

Miki

[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 <[hidden email]> wrote:

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.com/dataArtisans/flink-training-exercises/blob/master/src/main/java/com/dataartisans/flinktraining/exercises/datastream_java/windows/DrivingSegments.java

Evictor is used in order to clear the data by time stamp  but how can i clear the data  by the key  also ?

thanks ,

Miki

[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 <[hidden email]> wrote:

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 <[hidden email]> wrote:

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.com/dataArtisans/flink-training-exercises/blob/master/src/main/java/com/dataartisans/flinktraining/exercises/datastream_java/windows/DrivingSegments.java

Evictor is used in order to clear the data by time stamp  but how can i clear the data  by the key  also ?

thanks ,

Miki