Fwd: Global window keyBy

[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 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 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/blo
> b/master/src/main/java/com/dataartisans/flinktraining/exerci
> ses/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
>
>
>

Re: Global window keyBy

[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 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

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