Suchergebnisse für Anfrage "scala"
Verwenden von groupBy in Spark und Zurückkehren zu einem DataFrame
Ich habe Probleme beim Arbeiten mit Datenrahmen in Spark mit Scala. Wenn ich einen Datenrahmen habe, aus dem ich eine Spalte eindeutiger Einträge extrahieren möchte, verwende ichgroupBy Ich erhalte keinen Datenrahmen zurück. Zum Beispiel habe ...
Wie füge ich einen Spark-Datenrahmen am unteren Rand eines anderen Datenrahmens hinzu?
Ich kann nutzenwithcolumn, um einem Datenrahmen neue Spalten hinzuzufügen. Aber wie kann ich in Scala einem DataFrame neue Zeilen hinzufügen? Ich versuche, einem anderen Datenrahmen einen Datenrahmen hinzuzufügen. Entweder wie man Zeilen in ...
gib TopN aller Gruppen nach Gruppe mit Spark DataFrame
Ich habe einen Spark SQL DataFrame: user1 item1 rating1 user1 item2 rating2 user1 item3 rating3 user2 item1 rating4 ...Wie nach Benutzer gruppieren und dann @ zurückgebTopN Elemente aus jeder Gruppe, die Scala verwendet? Ähnlichkeitscode mit ...
Eine Variable, die in einer eigenen Definition verwendet wird?
Ein unendlicher Strom: val ones: Stream[Int] = Stream.cons(1, ones) Wie kann ein Wert in einer eigenen Deklaration verwendet werden? Es scheint, dass dies einen Compilerfehler erzeugen sollte, aber es funktioniert.
Matrix-Multiplikation in Apache Spark [geschlossen]
ch versuche, eine Matrixmultiplikation mit Apache Spark und Java durchzuführe Ich habe 2 Hauptfragen: Wie erstelle ich ein RDD, das eine Matrix in Apache Spark darstellen kann?Wie multipliziere ich zwei solche RDDs?
In Slick / Scala streamen
Ich schaue mir Scala / Slick-Streaming an und versuche zu verstehen, wie es funktioniert. Hier ist mein Testcode val bigdata = TableQuery[BigData] val x = db.stream(bigdata.result.transactionally.withStatementParameters(fetchSize ...
Bypass erste Zeile jeder Datei in Spark (Scala)
Ich verarbeite einen S3-Ordner mit csv.gz-Dateien in Spark. Jede csv.gz-Datei enthält eine Kopfzeile mit Spaltennamen. Die Art und Weise, wie ich die enthaltenen Daten in Spark lade, besteht darin, auf den Pfad / Ordner zu verweisen: val rdd = ...
Was ist der Unterschied zwischen Router mit injizierter Abhängigkeit und statischem Router in ScalaRouting of Play Framework?
Was ist der Unterschied zwischen dem Router mit injizierter Abhängigkeit und dem statischen Router in ScalaRouting of Play Framework? ie @Play-Framework-Dokumentation gibt an, dass der in Abhängigkeit injizierte Router verwendet wird, wenn eine ...
Typklasseninstanzen für Fallklassen mit genau einem Feld ausführen
Ich arbeite an einer CSV-Parsing-Bibliothek tabulate [http://nrinaudo.github.io/tabulate/]). Es werden einfache Typklassen zum Codieren / Decodieren verwendet: Das Codieren wird beispielsweise mit Instanzen von @ durchgeführCellEncoder (um eine ...
wie man neue geschachtelte Anmerkungen von Scala 2.8.0 benutzt
sieht aus wie wenn Scala 2.8.0 raus ist, können wir verschachtelte @ Annotationen in unseren Persistenzebenen verwenden. Aber wie? Kann jemand dies bitte von Java in Scala umwandeln? Vielen Dank @NamedQueries({ @NamedQuery(name = "findAll", ...