Was ist der richtige Weg, um entfernen Sie ein element aus einer Hazelcast Karte?

Brauche ich, um ein Element zu entfernen von Hazelcast verteilte Karte, und ich benutze so etwas wie dieser code (vereinfacht): 

  public void realeaseBatchesById(int Id) {

    Iterator<Map.Entry<Long, WorkingBatch>> it = workingMap.entrySet().iterator();

    while (it.hasNext()) {
        WorkingBatch value = it.next().getValue();
        if (value.getServer().getId() == idd) {
        it.remove();
        }
    }

    }

aber dieser code nicht den Wert entfernen, die Größe der Karte ist die gleiche, am Anfang, wie die Größe am Ende.

Wenn ich sehe, zu Hazelcast Javadoc ich sehe, dass diese Schnittstelle definiert nur das entfernen von Schlüssel und Schlüssel mit dem Wert. Bedeutet es, ich kann nicht verwenden Sie ein standard-Weg, wie man den Wert entfernen von der Karte?

  • Haben Sie versucht equals statt == ?
  • Es ist kein problem mit dem finden von Werten bestimmt, die für das entfernen - ich fand Sie. Funktioniert aber nicht entfernen Sie Sie über it.remove()
InformationsquelleAutor user2148736 | 2014-02-24
  1. 10

    Entfernen eines Elements aus einer Karte, die Sie nicht tun können, durch einen iterator. Der iterator ist eine temporäre Kopie der entryset und änderungen auf, die es noch nicht widerspiegeln, die auf die Inhalte der Karte.

    Ihr Ansatz ist nicht sehr skalierbar, da Sie die Iteration über alle Einträge in der Karte, stellen Sie sich vor Sie haben gigabytes von map-Einträgen.. etwa 50% benötigt werden, senden über die Linie, bevor Ihr Artikel gefunden wird.

    Wenn Sie möchten, um ein Element zu entfernen, können Sie tun:

    map.remove(somekey)

    Aber die große Frage ist: wie finden Sie Ihren Artikel. In Sie Fall, Ihr Artikel hat offenbar irgendeine Art von server.id, so dass Sie könnten einen index erstellen, der auf diese id, so können Sie eine schnelle suchen, und kombinieren Sie es mit:

    IMap.executeOnEntries(EntryProcessor entryProcessor, Predicate predicate);

    Wenn Sie erstellen ein Prädikat (das findet Sie Ihre Eingabe) und erstellen Sie ein Eingabe-Prozessor (das löschen können Sie Ihre Eingabe), können Sie eine viel mehr effiziente löschen.

    • Danke, das entfernen über Karte.entfernen(Taste) funktioniert bei mir. Ist dieser Vorgang thread-sicher oder muss ich mich kümmern? Ich kann iteriert werden, weil es auf der Karte gibt es etwa 20-30 Werte.
    • Alle Operationen auf der Karte sind threadsicher. Aber.. wenn Sie wollen, um mehrere Aktionen auf einer Karte in atomarer Weise, die Sie anwenden müssen, z.B. (pessimsitic) locking, optimistic locking, etc.
    • Sah ich Ihren letzten Kommentar auf github.com/hazelcast/hazelcast/issues/486 zeigt ein Beispiel EntryProcessor für diesen Anwendungsfall. Können Sie bestätigen, wenn eine solche EntryProcessor würde, löschen Sie den gesamten EINTRAG aus dem IMap-oder einfach nur den WERT mit der TASTE verknüpft.
    • Es entfernt den Eintrag. public static void main(String[] args){ HazelcastInstance hz = Hazelcast.newHazelcastInstance(); IMap map = hz.getMap("foo"); anzeigen.setzen(1,1); anzeigen.executeOnKey(1, new DeleteEP()); System.aus.println(map.size()); } public static class DeleteEP implementiert EntryProcessor{ @Override public Object process(Map.Eintrag) { Eintrag.setValue(null); return null; } }
    • Ich habe versucht zu löschen Millionen Einträge von Imap-mit-Prädikat-basierten Zustand:IMap.executeOnEntries(neue DeleteMillionsEntryProcessor(), Prädikat).Diese gelöschten Einträge von IMap als verifiziert mancenter Karte zählen. Aber, die genaue Anzahl der gelöschten Einträge gezeigt wurde unter "Hits". Ist es, weil die Löschung über EntryProcessor bezieht sich auf den Zugriff auf den Datensatz und mediensystemen es. Außerdem ist es eine Möglichkeit zum ausführen von GC manuell den Millionen der nicht referenzierte Objekte, die sich in meinen heap-Schwelle erreichen von 70% und meine Anwendung brechen.
    InformationsquelleAutor pveentjer
Schreibe einen Kommentar