Suchergebnisse für Anfrage "scala"
Wie konvertiere ich Scala RDD in Map
Ich habe ein RDD (Array von String)org.apache.spark.rdd.RDD[String] = MappedRDD[18] und um es in eine Karte mit eindeutigen IDs umzuwandeln. Ich tat 'val vertexMAp = vertices.zipWithUniqueId 'aber das gab mir einen anderen RDD vom ...
Running Spark Scala Beispiel fehlgeschlagen
Ich bin neu bei Spark und Scala. Ich habe ein IntelliJ Scala-Projekt mit SBT erstellt und build.sbt um einige Zeilen erweitert. name := "test-one" version := "1.0" scalaVersion := "2.11.2" libraryDependencies += "org.apache.spark" % ...
In Spark, was ist der richtige Weg, um ein statisches Objekt für alle Worker zu haben?
Ich habe mir die Dokumentation für Spark angesehen und erwähne Folgendes: ie API von @ Spark basiert in hohem Maße auf der Übergabe von Funktionen im Treiberprogramm, um auf dem Cluster ausgeführt zu werden. Es gibt zwei empfohlene ...
Intellij IDEA java.lang.NoSuchMethodError: scala.collection.immutable. $ Colon $ colon.hd $ 1 () Ljava / lang / Object
Ich habe folgende Funktion: def removeLast(list: List[Int]): List[Int] = list match { case List() => List() case List(x) => List() case x :: xs => x :: removeLast(xs) }Wenn ich es definiere und es von der sbt-Konsole verwende, funktioniert alles ...
Convert Java `sort` Signatur mit`? Super T` zu Scala (Generika)
Das Problem Anschauendiese Frag [https://stackoverflow.com/questions/16430355/translating-generic-%20wildcards-from-java-to-scala] zur Migration der Java-Signatur public <A extends Comparable<? super A>> void sort(List<A> list) { }to Scala, ...
Liste von scalaz.Validation kartieren und verkleinern / überklappen
Ich habe mit so etwas angefangen: def nonEmpty[A] = (msg: String) => (a: Option[A]) => a.toSuccess(msg) val postal: Option[String] = request.param("postal") val country: Option[String] = request.param("country") val params = (postal |> ...
Gibt es sequentielle Future.find?
Ich habe eine Nebenwirkung, def f(): Future[Int] = { val n = Random.nextInt() println(s"Generated $n") Future(n) }und ich möchte es wiederholt ausführen, bis das Prädikat true zurückgibt. def success(n: Int): Boolean = n % 2 == 0Mein Plan ist ...
Scala erhält Feld und Feldtyp einer Fallklasse
So versuche ich, das Feld und ihre Typen in eine Fallklasse zu bekommen. Im Moment mache ich es so typeOf[CaseClass].members.filter(!_.isMethod).foreach{ x => x.typeSignature match { case _:TypeOfFieldInCaseClass => do something ...
Wie kann ich Unit in Scala instanziieren?
Alles, was ich möchte, ist die Verwendung eines gleichzeitigen Sets (das anscheinend überhaupt nicht existiert). Java verwendetjava.util.concurrent.ConcurrentHashMap<K, Void> um dieses Verhalten zu erreichen. Ich möchte in Scala etwas Ähnliches ...
Kann eine while-Schleife mit Yield in Scala verwendet werden
Hier ist das Standardformat für for / yield in scala: Es wird eine Sammlung erwartet, deren Elemente die Iteration bestimmen. for (blah <- blahs) yield someThingDependentOnBlahIch habe eine Situation, in der eine unbestimmte Anzahl von ...