Anthony,

Streamer's addData() method is asynchronous, calling it doesn't mean that
the value momentarily ends up in cache. Streamer sends data to server nodes
in batches, and since you added only five entries, they were all sent in one
batch when you closed the streamer, therefore they were saved into cache at
the same time.

Streamer is designed to handle a lot of continuous events. If you want to
test expiration in your scenario, you can use simple cache puts instead -
they are synchronous.

Thanks!



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Question-regarding-possible-use-case-of-Sliding-Windows-tp530p547.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Reply via email to