Roman, Please check the following methods: * CacheContiniousQueryHandler (the filter usage): https://github.com/apache/ignite/blob/6955ac291352dd67c1f84a006cda512ee54f38bb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java#L994 * CacheContinuousQueryManager (the listener execution): https://github.com/apache/ignite/blob/master/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java#L376
- Denis On Sun, Jun 7, 2020 at 12:19 AM <roman.koria...@t-systems.com> wrote: > Hi Denis, > A big thank you for the answer. > Could you please tell me where can I find this logic in the sources. Which > package should I look into? > > -----Original Message----- > From: Denis Magda <dma...@apache.org> > Sent: Saturday, June 6, 2020 2:07 AM > To: dev <dev@ignite.apache.org> > Subject: Re: Continuous Queries with several remote filter on the same > cache > > Hi Roman, > > Every continuous query is a unique entity that is processed by servers > independently. With your example, the server node will execute all 20 > filters for every cache insert/update operation. The server will notify > through local listeners only those clients whose remote filters returned > 'true'. > > - > Denis > > > On Thu, Jun 4, 2020 at 8:44 PM <roman.koria...@t-systems.com> wrote: > > > Hi Community, > > > > I ask this question here because I haven't found the answer in the > > documentation. > > > > Could you please clarify how Continuous Queries work? What the > > behavior of Continuous Queries if we have several clients with > > different Remote Filters on the same cache? For example, if we have: > > one server node with cache and we have up to 20 client nodes each of > > them will execute Continuous Query on the same cache but with > > different Remote Filters. Will each client get the data according to > > its remote filter? Or it is supposed to have only one Remote Filter > > for all clients and every client should filter data in its local event > listener? > > I would be grateful if you send some link which describes the behavior > > of Continuous Queries more thoroughly. > > Best regards, > > Roman > > >
