I answer my own question, I added something like:
public boolean evaluate(
CacheEntryEvent<? extends String, ? extends String> event)
throws CacheEntryListenerException {
return event.getEventType().equals(javax.cache.event.EventType.CREATED);
}
In the query.setRemoteFilter and looks like is working. I notice is
executing the code in the "client" or "caller" and the "filtering" in the
nodes where the cache is distributed.
I'm correct in this assumptions?
Documentation for reference:
https://apacheignite.readme.io/docs/continuous-queries
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Cache-Events-Questions-tp1090p1252.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.