Suchergebnisse für Anfrage "scala"

2 die antwort

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 ...

2 die antwort

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 ...

2 die antwort

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: ...

TOP-Veröffentlichungen

2 die antwort

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 ...

4 die antwort

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 ...

4 die antwort

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 ...

2 die antwort

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, ...

8 die antwort

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) ...

4 die antwort

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 ...

4 die antwort

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.