Re: Continuous Query on a varying set of keys

2020-05-26 Thread Ilya Kasnacheev
Hello! Yes, using other continuous query to watch changes of this set looks OK. Of course there will be some yak shaving to do. Regards, -- Ilya Kasnacheev вт, 26 мая 2020 г. в 12:28, zork : > Thanks. > So I can think of two ways using which such a set could be maintained by > the > remote

Re: Continuous Query on a varying set of keys

2020-05-26 Thread zork
Thanks. So I can think of two ways using which such a set could be maintained by the remote node: 1. The remote node listens to a new topic through which the local node sends it a message whenever the set changes. 2. Or, the local node puts the set values in a new table in the cache itself and

Re: Continuous Query on a varying set of keys

2020-05-26 Thread Ilya Kasnacheev
Hello! No, updating local set will not be sent over to the remote node, but on the remote node you can probably update it from your filter: qry.setRemoteFilterFactory(new Factory>() { @Override public CacheEntryEventFilter create() { return new

Re: Continuous Query on a varying set of keys

2020-05-26 Thread zork
Hi, Sorry but I could not get it to work. The standard way of defining a remote filter as shown in sample repo is something like: qry.setRemoteFilterFactory(new Factory>() { @Override public CacheEntryEventFilter create() { return new

Re: Continuous Query on a varying set of keys

2020-05-18 Thread Ilya Kasnacheev
Hello! Remote filter is code. It can execute arbitrary logic. It can adjust to what it needs to filter, change its own behavior with time. Regards, -- Ilya Kasnacheev пн, 18 мая 2020 г. в 15:40, zork : > Hi Ilya, > Thanks for your response. > I'm aware of remote filters but can these filters

Re: Continuous Query on a varying set of keys

2020-05-18 Thread zork
Hi Ilya, Thanks for your response. I'm aware of remote filters but can these filters be modified once the query is already attached? Because if not, then this would not solve my use case as the filter would always give me updates on a fixed subset of keys, however in my case this subset is varying

Re: Continuous Query on a varying set of keys

2020-05-18 Thread Ilya Kasnacheev
Hello! Continuous query has a notion of 'remote filter'. This is a piece of code which is executed near data (on server nodes) to determine if the update needs to be sent over network. https://apacheignite.readme.io/docs/continuous-queries#remote-filter If you define a proper remote filter,

Continuous Query on a varying set of keys

2020-05-17 Thread zork
Hi, We have a table in ignite cache which would have say around 1Mn entries at anytime. Now we wish to listen on updates on a subset of these keys (say 5-10 thousand keys) and this subset keeps on changing as the user subscribes/unsubscribes to these keys. The way it is currently working is one