Suchergebnisse für Anfrage "scala"
Spark Dataframe groupBy mit der Sequenz als Schlüsselargumente [duplizieren]
Diese Frage hat hier bereits eine Antwort: Multiple Aggregate-Operationen für dieselbe Spalte eines Spark-Datenrahmens [/questions/34954771/multiple-aggregate-operations-on-the-same-column-of-a-spark-dataframe] 2 AntwortenIch habe einen Funken ...
VectorAssembler unterstützt nicht den StringType-Typ scala spark convert
Ich habe einen Datenrahmen, der Zeichenfolgenspalten enthält, und ich plane, ihn als Eingabe für k-means unter Verwendung von spark und scala zu verwenden. Ich konvertiere meine Zeichenfolgenspalten des Datenrahmens mit der ...
Verwenden von Futures innerhalb von Spark
Ein Spark-Job erstellt einen Remote-Webdienst für jedes Element in einer RDD. Eine einfache Implementierung könnte ungefähr so aussehen: def webServiceCall(url: String) = scala.io.Source.fromURL(url).mkString rdd2 = rdd1.map(x => ...
Get Betrag von Geber Zeichenfolge mit Regex [duplizieren]
Diese Frage hat hier bereits eine Antwort: Währung regulärer Ausdruck [/questions/13848570/currency-regular-expression] 3 answers Also ich habe diese Zeichenfolge: val value = "\nValue is €2,927"ie kann ich diesen Betrag analysiere2927, ...
Scala "<-" zum Verständnis
Ich habe festgestellt, dass Scala immer eine "natürliche Erklärung" für alles hat. Immer so etwas wie "ohh, aber das ist nur eine Funktion, die für dieses und jenes Objekt mit diesem und jenem Parameter aufgerufen wird". In gewisser Weise ist ...
Wie man Byte [] [] mit Kryo-Serialisierung für Funken registriert
Ich versuche, die Kryo-Serialisierung für Funken vollständig zu nutzen. Rahme .set("spark.kryo.registrationRequired", "true")Dies teilt mir mit, welche Klassen registriert werden müssen. Ich habe ungefähr 40 Klassen angemeldet, einige meiner ...
Listenelemente gruppieren, indem Sie sie mit ihren Nachbarn vergleichen
Was ist die eleganteste Methode zum Gruppieren einer Werteliste in Gruppen auf der Grundlage ihrer Nachbarwerte? Der größere Kontext, den ich habe, besteht aus einer Liste von Zeilen, die in Absätze gruppiert werden müssen. Ich möchte sagen ...
Warum kann ich eine Liste [Option] nicht mit einem Unterstrich versehen?
Warum kann ich schreiben val flat: List[Int] = List(Some(1), Some(2)).flatMap(i => i)Aber nich val flat: List[Int] = List(Some(1), Some(2)).flatMap(_)
Zweck der "return" -Anweisung in Scala?
Gibt es einen wirklichen Grund für die Bereitstellung desreturn Aussage in Scala? (abgesehen davon, dass es "Java-freundlicher" ist)
Warum kann Scala Function serialisieren, PartialFunction jedoch nicht?
Ich habe 2 Funktionen (von denen eine teilweise ist), die unter einem Objekt ähnlich definiert sind: val partialFn: scala.PartialFunction[String, Int] = new AbstractPartialFunction[String, Int] { override def isDefinedAt(v: String): Boolean = { ...