Suchergebnisse für Anfrage "reduce"
usgabe eines Mapreduce-Programms als Eingabe in ein anderes Mapreduce-Progra
Ich versuche ein einfaches Beispiel, in dem die Ausgabe eines MapReduce-Jobs die Eingabe eines anderen MapReduce-Jobs sein soll. Der Ablauf sollte folgendermaßen aussehen:Mapper1 --> Reducer1 --> Mapper2 --> Reducer2 (Die Ausgabe von Mapper1 ...
Spark groupByKey alternative
Nach den Best Practices von Databricks ist SparkgroupByKey sollte vermieden werden, da SparkgroupByKeyie @ -Verarbeitung funktioniert so, dass die Informationen zuerst zwischen den Mitarbeitern gemischt werden und dann die Verarbeitung ...
Muss die Identität bei der Stream-Reduction-Methode immer 0 für die Summe und 1 für die Multiplikation sein?
Ich fahre mit dem Lernen von Java 8 fort. Ich habe interessantes Verhalten gefunden: lets siehe Codebeispiel: // identity value and accumulator and combiner Integer summaryAge = Person.getPersons().stream() //.parallel() //will return ...
Reduce Array zum Setzen in Swift
Ich versuche, ein Array von Objekten in Swift auf eine Menge zu reduzieren, und das ist mein Code: objects.reduce(Set<String>()) { $0.insert($1.URL) } Ich erhalte jedoch eine Fehlermeldung: Type of expression is ambiguous without more ...
Wie implementiere ich eine allgemeinere Reduktionsfunktion, um ein vorzeitiges Verlassen zu ermöglichen?
reduce (akafoldL in FP) ist die allgemeinste iterative Funktion höherer Ordnung in Javascript. Sie können zum Beispiel implementieren,map oderfilter bezüglichreduce. Ich habe eine imperative Schleife verwendet, um den Algorithmus besser zu ...
RDD aufteilen und Aggregation für neue RDDs durchführen
Ich habe eine RDD von(String,String,Int). Ich möchte es basierend auf den ersten beiden Zeichenfolgen reduzierenUnd dann basierend auf dem ersten String möchte ich den (String, Int) gruppieren und sortierenNach dem Sortieren muss ich sie in ...
Spark: Unterschied der Semantik zwischen reduct und reductByKey
n der Dokumentation von Spark heißt es, dass die RDD-Methodereduce [http://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.rdd.RDD] erfordert eine assoziative UND kommutative Binärfunktion. Allerdings ist die ...
Mit der Funktion "Verkleinern" ein Array zurückgeben
Warum erhalte ich eine Fehlermeldung, wenn ich die Push-Funktion innerhalb der Reduce-Funktion verwenden möchte, um ein neues Array zurückzugeben. Wenn ich jedoch die concat-Methode innerhalb der Funktion "Verkleinern" verwende, wird problemlos ...
Reduktionen parallel in logarithmischer Zeit
Gegebenn partialsummen es ist möglich alle partialsummen in log2 parallelen schritten zu summieren. Angenommen, es gibt acht Threads mit acht Teilsummen:s0, s1, s2, s3, s4, s5, s6, s7. Dies könnte in @ reduziert werdlog2(8) = 3 sequentielle ...
Wie brechen Sie auf Methode reduzieren
Wie kann ich die Iteration bei der Reduktionsmethode unterbrechen? zu for (var i = Things.length - 1; i >= 0; i--) { if(Things[i] <= 0){ break; } }; reduziere Things.reduce(function(memo, current){ if(current <= 0){ //break ??? //return; <-- ...