Suchergebnisse für Anfrage "scala"
Wie filtere ich Zeilen basierend darauf, ob sich ein Spaltenwert in einem Satz von Zeichenfolgen in einem Spark-DataFrame befindet?
Gibt es eine elegantere Methode zum Filtern anhand von Werten in einem String-Satz? def myFilter(actions: Set[String], myDF: DataFrame): DataFrame = { val containsAction = udf((action: String) => { actions.contains(action) ...
Erklärung der Faltmethode des Funken RDD
Ich verwende Spark-1.4.0, das für Hadoop-2.4 (im lokalen Modus) vorgefertigt ist, um die Summe der Quadrate einer DoubleRDD zu berechnen. Mein Scala-Code sieht aus wie sc.parallelize(Array(2., 3.)).fold(0.0)((p, v) => p+v*v)nd es gab ...
Wie lege ich eine Systemeigenschaft für mein Projekt in sbt fest?
Ich bin sicher, ich vermisse etwas wirklich Einfaches ... Ich möchte die Systemeigenschaft einstellenjava.awt.headless zutrue für mein sbt projekt. Das @ lespage auf Eigenschaften [http://code.google.com/p/simple-build-tool/wiki/Properties] Ich ...
Was sind die Unterschiede zwischen einer Scala Future und einer Java Future
Gibt es konzeptionelle, funktionale oder mechanische Unterschiede zwischen einer Scala Future und einer Java Future? Konzeptionell kann ich keine Unterschiede feststellen, da beide darauf abzielen, einen Mechanismus für die asynchrone Berechnung ...
Spray `detach` Direktive
Gab den folgenden Spraycode: object Main extends App with SimpleRoutingApp { implicit val system = ActorSystem("my-system") val pipeline: HttpRequest => Future[String] = sendReceive ~> unmarshal[String] startServer(interface = "localhost", port ...
Nicht in der Lage, einen Akkumulator vom Typ String zu deklarieren
Ich versuche, eine Akkumulatorvariable vom Typ String in der Scala-Shell (Treiber) zu definieren, erhalte jedoch weiterhin den folgenden Fehler: - scala> val myacc = sc.accumulator("Test") <console>:21: error: could not find implicit value for ...
Holen Sie sich den gesamten HttpResponse-Body als String mit Akka-Streams HTTP
Ich versuche zu verstehen, wie man das neue @ benutakka.http Bibliothek. Ich möchte eine http-Anfrage an einen Server senden und den gesamten Antworttext als einzelnen String lesen, um ein @ zu erzeugeSource[String,?]. Hier ist die beste ...
convert java.util.Map [String, Object] to scala.collection.immutable.Map [String, Any]
Wie konvertiere ich java.util.Map [String, Object] in scala.collection.immutable.Map [String, Any], sodass alle Werte in der ursprünglichen Zuordnung (Ganzzahlen, Boolesche Werte usw.) in den richtigen Wert konvertiert werden gut in Scala arbeiten.
Wann ist ein Rückgabetyp für Methoden in Scala erforderlich?
Der Scala-Compiler kann häufig Rückgabetypen für Methoden herleiten, aber unter bestimmten Umständen muss der Rückgabetyp angegeben werden. Bei rekursiven Methoden muss beispielsweise ein Rückgabetyp angegeben werden. Ich stelle fest, dass ...
Customize SparkContext using sparkConf.set (..) bei Verwendung von spark-shell
In Spark gibt es drei Hauptoptionen zum Festlegen der Optionen für dasSparkConf verwendet, um das @ zu erstellSparkContext: As Eigenschaften in der conf / spark-defaults.conf. B. die Zeile:spark.driver.memory 4gAls Argumente für Spark-Shell ...