Suchergebnisse für Anfrage "scala"
Generic Numeric division
Als allgemeine Regel können wir jeden Wert eines beliebigen Zahlentyps durch einen beliebigen Wert ungleich Null eines beliebigen Zahlentyps dividieren und ein vernünftiges Ergebnis erhalten. 212.7 / 6 // Double = 35.449999999999996 77L / 2.1F ...
Warum gibt diese Scala-Zeile eine Einheit zurück?
Hier ist ein bisschen Scala-Code, um die Werte von 1 bis 9 zu summieren, die durch 3 oder 5 teilbar sind. Warum gibt Zeile 5 eine Unit und keinen Booleschen Typ zurück? object Sample { def main(args : Array[String]) { val answer = (1 ...
Kette funktioniert anders
ür die Verkettung von @Scala-Funktionen stehen folgende Methoden zur Verfügung: fn1.andThen(fn2) fn1.compose(fn2)Aber wie kann dieser Fall geschrieben werden: Ich habe FunktioncleanUp() welches immer als letzter Schritt aufgerufen werden muss. ...
Verwenden Sie mehr als eine collect_list in einer Abfrage in Spark SQL
Ich habe den folgenden Datenrahmendata: root |-- userId: string |-- product: string |-- rating: doubleund die folgende Abfrage: val result = sqlContext.sql("select userId, collect_list(product), collect_list(rating) from data group by ...
Object Cache auf Spark-Executoren
ine gute Frage für Spark-Experte Ich verarbeite Daten in einemmap operation (RDD). Innerhalb der Mapper-Funktion muss ich nach Objekten der Klasse @ sucheA zur Verarbeitung von Elementen in einer RDD. Da dies auf Executoren UND Erstellung von ...
Scala Spark enthält vs. enthält nicht
Ich kann Tupel in einer RDD wie unten beschrieben mit "contain" filtern. Aber was ist mit dem Filtern einer RDD mit "enthält nicht"? val rdd2 = rdd1.filter(x => x._1 contains ".")Ich kann die Syntax dafür nicht finden. Vorausgesetzt, es ist ...
N-mal Spark Row replizieren
Ich möchte eine Zeile in einem DataFrame duplizieren. Wie kann ich das tun? Zum Beispiel habe ich einen DataFrame, der aus 1 Zeile besteht, und ich möchte einen DataFrame mit 100 identischen Zeilen erstellen. Ich habe die folgende Lösung ...
scala generische Funktion Rückgabetyp
Ich habe versucht, eine Funktion mit einem generischen Rückgabetyp zu schreiben, aber sie funktioniert nur, wenn ich den Rückgabetyp umgewandelt habe. Bitte beachten Sie die FunktiongetSomething() unten erwartete ich, dass es ohne das Casting ...
Das Typensystem in Scala ist Turing vollständig. Beweis? Beispiel? Leistungen
Es gibt Behauptungen, dass das Typensystem von Scala vollständig ist. Meine Fragen sind: Gibt es einen formellen Beweis dafür? Wie würde eine einfache Berechnung im Scala-Typsystem aussehen? Ist das für Scala von Nutzen - die Sprache? Ist ...
Scala: Spark SQL to_date (unix_timestamp) gibt NULL @ zurü
Spark Version: spark-2.0.1-bin-hadoop2.7 Scala: 2.11.8 Ich lade eine unformatierte CSV in einen DataFrame. In csv wird die Spalte zwar im Datumsformat unterstützt, sie wird jedoch als 20161025 anstatt als 2016-10-25 geschrieben. Der ...