Apache Ignite: Remote-Filter-Factory auf kontinuierliche Abfrage setzen

Question

Guten Morgen Jungs,

Ich muss wissen, ob mir jemand erklären kann, wie funktioniert der Remote-Filter auf kontinuierliche Abfrage.

Kann ich ein HashSet definieren, um den Cache-Schlüssel zu filtern? Kann mir jemand ein gutes Beispiel geben, um meine Zweifel zu klären? Dies ist mein Code, der nicht funktioniert, wobei Filter ein HashSet ist. Ich denke, dass der Serverknoten nach der Ausführung im Deadlock ist.

  qry.setRemoteFilterFactory(new Factory<CacheEntryEventFilter<String, JSONObject>>() { 
       @Override public CacheEntryEventFilter<String, JSONObject> create() { 
        return new CacheEntryEventFilter<String, JSONObject>() { 
         @Override public boolean evaluate(CacheEntryEvent<? extends String, ? extends JSONObject> e) { 

          return Filter.contains(e.getKey()); 
         } 
        }; 
       } 
      }); 

Vielen Dank im Voraus Jungs.

Answer 1

Es ist nicht klar, woher du die Karte nimmst und was nicht funktioniert. Beachten Sie, dass der Filter auf Serverknoten aufgerufen wird. Daher muss diese Karte ordnungsgemäß serialisiert und an alle Knoten gesendet werden.

Im Allgemeinen basiert der Filter auf einem Schlüssel/Wert-Paar und ist normalerweise zustandslos (z. B. nur Benachrichtigungen über Aktualisierungen für Ereignisse mit einem bestimmten Status). Eine solche Karte ist in großen Datenmengen wahrscheinlich zu groß.