Suchergebnisse für Anfrage "scala"
Das grundlegendste Scala-Projekt mit Maven erstellen?
Ich benutze Maven 3, um ein neues Scala-Projekt zu erstellen. Soweit ich weiß, können Sie mit Maven auf folgende Weise ein neues Projekt erstellen: mvn archetype:generate Vielleicht habe ich etwas verpasst, aber ich konnte nicht einmal eine ...
Nachteile des Scala-Systems gegenüber Haskell?
Ich habe gelesen, dass das Typensystem von Scala durch die Java-Interoperabilität geschwächt ist und daher nicht die gleichen Funktionen wie das Typensystem von Haskell ausführen kann. Ist das wahr? Liegt die Schwäche an der Typ-Löschung, oder ...
Wie ändere ich den Spaltentyp in DataFrames von "String" in "Datum"?
Ich habe einen Datenrahmen mit zwei Spalten (C, D), die als Zeichenfolgenspaltentyp definiert sind, aber die Daten in den Spalten sind tatsächlich Datumsangaben. Spalte C hat beispielsweise das Datum "01-APR-2015" und Spalte D das Datum ...
Wie verwende ich java.String.format in Scala?
Ich versuche ein @ zu benutz.format Methode eines Strings. Wenn ich jedoch% 1,% 2 usw. in die Zeichenfolge einfüge, wird java.util.UnknownFormatConversionException ausgelöst und zeigt auf ein verwirrendes Java-Quelltextstück: private void ...
Wie man mit Spark @ schnell eine Datei aus HDFS in map () lie
Ich muss in jeder Map eine andere Datei lesen (), die Datei ist in HDFS val rdd=sc.parallelize(1 to 10000) val rdd2=rdd.map{x=> val hdfs = org.apache.hadoop.fs.FileSystem.get(new java.net.URI("hdfs://ITS-Hadoop10:9000/"), ...
akka-stream - Wie man das letzte Element eines Streams in einem Flow / Graph anders behandelt
Ich versuche Akka Streams zu implementierenFlow konvertiert einen Stream von JSON-Objekten in einen Stream eines einzelnen Arrays von JSON-Objekten. Ich kann nutzenConcat, um ein "[" vor und "]" nach sowie @ hinzuzufügZip, um Kommas zwischen die ...
Covariant Typeparameter in Scala muss in Java-Schnittstelle invariant sein
Ich habe eine Eigenschaft, die so aussieht (weitere Informationen finden Sie unterdiese verwandte Frage von mir selbst [https://stackoverflow.com/questions/3695990/inheritance-and-automatic-type-conversion] obwohl ich nicht denke, wird es für ...
Gläser zu einem Spark-Job hinzufügen - spark-submit
True ... es wurde schon viel diskutiert. Allerdings gibt es viele Unklarheiten und einige der bereitgestellten Antworten ... einschließlich des Duplizierens von JAR-Referenzen in der JAR- / Executor- / Treiberkonfiguration oder in den ...
Wie kann Spark ein mit JSON-Escapezeichen versehenes String-Feld als JSON-Objekt analysieren lassen, um auf die richtige Struktur in DataFrames zu schließen?
Ich habe als Eingabe eine Reihe von Dateien, die als einzelnes JSON-Objekt pro Zeile formatiert sind. Das Problem ist jedoch, dass ein Feld in diesen JSON-Objekten eine mit JSON-Escapezeichen versehene Zeichenfolge ist. Beispie { "id":1, ...
Warum benötigt Scala einen Rückgabetyp für rekursive Funktionen?
In dem Code-Snippet unten habe ich einen rekursiven Funktionsaufruf, der verwendet wird, um einen erneuten Versuch zu erleichtern, wenn ein Netzwerkaufruf fehlschlägt (Amazon SimpleDB gibt gelegentlich einen 503 zurück und erfordert einen ...