Suchergebnisse für Anfrage "scala"
Random Partitioner-Verhalten auf dem verbundenen RDD
Ich versuche, zwei Datensätze zu verbinden. Eine vom Typ (Id, salesRecord) eine andere (Id, Name). Der erste Datensatz wird von HashPartitioner und der zweite von Custom Partitioner partitioniert. Wenn ich diesen RDDs nach ID beitrete ...
Anwenden von IndexToString auf den Feature-Vektor in Spark
Kontext Ich habe einen Datenrahmen, in dem alle kategorialen Werte mit StringIndexer indiziert wurden. val categoricalColumns = df.schema.collect { case StructField(name, StringType, nullable, meta) => name } val categoryIndexers = ...
Ist es möglich, Begleitklassen / -module im Scala-Interpreter zu definieren?
Es ist oft praktisch, Dinge im Scala-Interpreter zu testen. Ein Problem ist jedoch, dass ich Code umstrukturieren muss, der implizite Konvertierungen verwendet, da ein Objekt mit demselben Namen wie eine vorhandene Klasse definiert wirnich mache ...
Wie laufen alle skalierten eines Multi-Module-SBT mit Intellij?
Ich kann rennen ein spezifischer Scala Testlicken Sie mit der rechten Maustaste auf den Test und wählen Sie "@"runoder wenn ich es schon einmal ausgeführt habe, wählen Sie den Test im Startmenü>run...Ich kann alle Junit-Tests ausführen, indem ...
Verschachtelte Scala-Singletons aus Java-Code
Ich habe den folgenden Scala (2.8) Code: object A { val message = "hello" object B { val message = "world" } }Und eine ähnliche Java-Klasse: public class C { public static String message() { return "HELLO"; } public static class D { public ...
Zweck von Scalas Symbol? [Duplikat
Mögliches Duplizieren: Was sind einige Anwendungsbeispiele für Symbolliterale in Scala? [https://stackoverflow.com/questions/780287/what-are-some-example-use-cases-for-symbol-literals-in-scala] Was ist der Zweck von Symbol und warum verdient ...
Überprüfen, ob sich ein RDD-Element in einem anderen befindet, mithilfe der Kartenfunktion
Ich bin neu bei Spark und habe mich über Schließungen gewundert. Ich habe zwei RDDs, von denen eine eine Liste mit IDs und Werten und die andere eine Liste mit ausgewählten IDs enthält. Mit einer Map möchte ich den Wert des Elements erhöhen, ...
Kann keine JSON-Antwort mit Play Framework und Postgresql zurückgegeben werden?
Ich versuche, JSON-Antwortdaten aus der Postgresql-Datenbank mit dem Play Framework (Scala) zurückzugeben. Ich habe Folgendes versucht, bei dem ich meine json-Antwortausgabe nicht zurückgeben kann. Ich habe einige JSON-Objekte in meiner ...
Elemente aus einer HList holen
Ich habe mit HList rumgespielt und Folgendes funktioniert wie erwartet: val hl = 1 :: "foo" :: HNil val i: Int = hl(_0) val s: String = hl(_1) Ich kann den folgenden Code jedoch nicht zum Laufen bringen (nehmen wir für einen Moment an, dass ...
java.io.IOException: Die ausführbare Datei null \ bin \ winutils.exe konnte in den Hadoop-Binärdateien nicht gefunden werden. Funke Eclipse auf Windows 7
Ich kann kein einfaches @ ausführspark Job inScala IDE (Maven Spark-Projekt) installiert aufWindows 7 Spark Core-Abhängigkeit wurde hinzugefügt. val conf = new SparkConf().setAppName("DemoDF").setMaster("local") val sc = new SparkContext(conf) ...