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 <miko5...@gmail.com> 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 > > <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
