Suchergebnisse für Anfrage "scala"
Spark Task mit Lag Window Funktion nicht serialisierbar
Ich habe festgestellt, dass nach der Verwendung einer Window-Funktion über einen DataFrame beim Aufrufen einer map () mit einer Funktion Spark eine "Task nicht serialisierbar" zurückgibt. Ausnahme Dies ist mein Code: val ...
Wie übergebe ich Array [Seq [String]] an Apache Spark UdF? (Fehler: Nicht zutreffend)
Ich habe die folgenden Apache Spark UdF in Scala: val myFunc = udf { (userBias: Float, otherBiases: Map[Long, Float], userFactors: Seq[Float], context: Seq[String]) => var result = Float.NaN if (userFactors != null) { var contexBias = 0f for (cc ...
Wie verwende ich die programmatische Funkenübertragung?
Es gibt eine neuere Funktion (Frühjahr 2015), mit der anscheinend ein Funkenjob programmgesteuert übergeben werden soll. Hier ist der JIRAhttps: ...
winutils spark windows installation
Ich versuche Spark 1.6.1 unter Windows 10 zu installieren und habe bisher Folgendes getan ... Downloaded spark 1.6.1, entpackt in ein Verzeichnis und setze dann SPARK_HOMEDownloaded scala 2.11.8, entpackt in ein Verzeichnis und setzt ...
Shapeless findet keine Implicits im Test, kann aber in REPL
Ich habe eine Fallklasse, die so aussieht: case class Color(name: String, red: Int, green: Int, blue: Int) Ich verwende Shapeless 2.3.1 mit Scala 2.11.8. Ich sehe ein anderes Verhalten als mein Test und die REPL, wenn es darum geht, den ...
Play WS API: Anforderungsraten drosseln
Ich verwende die asynchrone Play WS Scala-API, um einen RESTful-Service abzufragen. Ich frage mich, wie ich ein @ verarbeiten könnList enthält Anforderungs-URLs, die über @ aufgerufen werden sollWSClient, aber nicht mehr als eine Anfrage pro ...
erschieben von Spark DataFrame von Python nach Scala mit Zeppel
Ich habe einen Funken DataFrame in einem Python-Absatz in Zeppelin erstellt. sqlCtx = SQLContext(sc) spDf = sqlCtx.createDataFrame(df)unddf ist ein Pandas-Datenrahmen print(type(df)) <class 'pandas.core.frame.DataFrame'>was ich tun möchte, ...
Bereich mit inklusive Endwert erstellen, wenn Sie
Gibt es eine Möglichkeit, einen Bereich zu erstellen, der enthält der Endwert bei Verwendung eines nicht ausgerichteten Schritts? Zum Beispiel ergibt sich folgendes: scala> Range.inclusive(0, 35, 10) ...
Blowfish verschlüsselt in Java / Scala und entschlüsselt in bash
Ich versuche, ein Tool zum Entschlüsseln von Inhalten in Bash zu erstellen, die in einer Scala-Anwendung verschlüsselt wurden: Aber zuerst muss es mir gelingen, die gleiche Nachricht in beiden Sprachen zu codieren und sie gleich zu ...
Wo kann ich Scala-Quelldosen herunterladen (scala-library-src.jar etc.)
Ich versuche, IntelliJ Idea Scala-Plugin zu verwenden, aber es heißt, es möchte scala-library-src.jar, scala-swing-src.jar, scala-dbc-src.jar. Wo kann ich diese Dateien herunterladen? Ich benutze Scala 2.8.