Val, thank you for your response. I'm talking about the first case. Ideally, periodically get the size of the cache (with sliding window 2 minutes) with every update and then save that result. But when I try a small example, it doesn't work the way I want.
For instance, I configure a sliding window of 2 seconds: cfg.setExpiryPolicyFactory(FactoryBuilder.factoryOf(new ModifiedExpiryPolicy(new Duration(SECONDS, 2)))); I control the stream to add 5 points of data at one second intervals to this cache. When I run the query "select _val,count(_val) as cnt from String group by _val", I get 5 points of data, instead of 2. Shouldn't data older than 2 seconds be evicted? That's what I thought, except my query returns all the data I streamed. Thank you, Anthony -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Question-regarding-possible-use-case-of-Sliding-Windows-tp530p535.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
