Wie bestellt man Ergebnisse von couchbase mit Bulk bekommt

Question

Ich versuche, die Leistung der Abfrage einer Couchbase-Ansicht zu verbessern, indem Async verwendet wird. Ich habe ihre Dokumentation über die richtige Art und Weise zu lesen, dies zu tun, es geht so etwas wie:

Cluster cluster = CouchbaseCluster.create(); 
Bucket bucket = cluster.openBucket(); 


List<JsonDocument> foundDocs = Observable 
.just("key1", "key2", "key3", "key4", "key5") 
.flatMap(new Func1<String, Observable<JsonDocument>>() { 
    @Override 
    public Observable<JsonDocument> call(String id) { 
     return bucket.async().get(id); 
    } 
}) 
.toList() 
.toBlocking() 
.single(); 

Welche großen und schnell funktioniert, aber da ich auf der Reihenfolge der Ergebnisse verlassen, scheint es, dass ich tun muss etwas zusätzliche Arbeit, um die Ergebnisse geordnet zu halten. Im obigen Beispiel enthält die JsonDocument-Liste alle 5 Dokumente, aber die Reihenfolge ändert sich zufällig von Anruf zu Anruf. Gibt es eine elegante Möglichkeit, das Ergebnis mithilfe von JavaRx-Funktionen oder Couchbase Java SDK-Funktionen zu bestellen?

Die einzige Lösung, die ich mir vorstellen kann, speichert die Ergebnisse in eine HashMap und dann die ursprüngliche Liste von IDs mit dieser HashMap in eine geordnete Liste von JsonDocuments transformieren.

Answer 1

Statt flatMap, Sie können entweder:

• concatMap: Auftrag wird, behalten aber eigentlich für jeden inneren GET warten zu vervollständigen vor dem Abfeuern des nächsten (könnte zur sequenziellen Ausführung mit weniger Leistung zurückkehren)
• concatMapEager: wird sofort interne Observables subscriben (so auslösen innere GET). Behält die Reihenfolge bei, indem Antworten gepuffert werden, die nicht in der richtigen Reihenfolge ankommen, bis sie mit dem richtigen Index in der Sequenz wiedergegeben werden können. Best of zwei Welten in Bezug auf Bestellung und Leistung.

Answer 2

würde ich Zip-Operator verwenden, um alle Ihre Observablen verketten, und dann, wenn sie Dokumente Ergebnisse in der Liste hinzufügen, fertig

@Test 
public void zipObservables() { 
    Observable<String> oKey1 = Observable.just("key1").doOnNext(getDocument()); 
    Observable<String> oKey2 = Observable.just("key2").doOnNext(getDocument()); 
    Observable<String> oKey3 = Observable.just("key3").doOnNext(getDocument()); 
    Observable<String> oKey4 = Observable.just("key4").doOnNext(getDocument()); 

    List<Observable<String>> observables = Arrays.asList(oKey1,oKey2,oKey3,oKey4); 
    List<Object> foundDocs = Observable.zip(observables, Arrays::asList) 
      .toBlocking() 
      .single(); 
} 

private Action1<String> getDocument() { 
    return id -> bucket.async().get(id); 
} 

können Sie mehr Zip Beispiele sehen hier https://github.com/politrons/reactive/blob/master/src/test/java/rx/observables/combining/ObservableZip.java