Hi,
  It shouldn't work like you described:
  Continuous query clients should only be receiving the records that are
pertinent to their filters/transformers.

  verify the continuous query definitions using the appropriate view:
https://apacheignite.readme.io/docs/continuous_queries

  take a look at : https://apacheignite.readme.io/docs/continuous-queries

  and the example here: 
https://github.com/apache/ignite/blob/master/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java

  Send a reproducer (And the version you are on) and I'll take a look.

Thanks, Alex


  



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Reply via email to