Suchergebnisse für Anfrage "scala"
Zeilensummenspalte über eine Spaltenliste in Spark Dataframe hinzufügen
Ich habe einen Spark-Datenrahmen mit mehreren Spalten. Ich möchte dem Datenrahmen eine Spalte hinzufügen, die eine Summe einer bestimmten Anzahl von Spalten ist. Zum Beispiel sehen meine Daten so aus: ID var1 var2 var3 var4 var5 a 5 7 9 12 13 b ...
Aggregieren mehrerer Spalten mit benutzerdefinierter Funktion in Spark
Ich habe mich gefragt, ob es eine Möglichkeit gibt, eine benutzerdefinierte Aggregationsfunktion für Spark-Datenrahmen über mehrere Spalten anzugeben. Ich habe eine Tabelle wie diese vom Typ (Name, Artikel, Preis): john | tomato | 1.99 john | ...
In Scala ist es möglich, ein Skript zu schreiben, das auf ein anderes Skript verweist
ch versuche derzeit, mithilfe von Scala-Skripten den Lebenszyklus einer MySQL-Datenbank zu steuern, anstatt MS-DOS-Skripten zu verwenden (ich arbeite unter Windows XP Ich möchte ein Konfigurationsskript haben, das nur ...
Warum brauchen wir Nil beim Erstellen von List in Scala? [Duplikat
Diese Frage hat hier bereits eine Antwort: Warum wird Nil am Ende einer mit dem cons-Operator erstellten Liste benötigt? [/questions/22881671/why-is-nil-required-at-the-end-of-a-list-built-using-the-cons-operator] 3 answersIch habe eine ...
olen Sie sich mehr als 20 Zeilen und zeigen Sie den vollen Wert der Spalte in der Spark-Shell a
Ich benutzeCassandraSQLContext von Spark-Shell, um Daten von Cassandra abzufragen. Also, ich möchte zwei Dinge wissen, wie man mit @ mehr als 20 Zeilen hoCassandraSQLContext und zweitens, wie kann ich den vollen Wert der Spalte anzeigen. Wie Sie ...
Anmerken von Konstruktorparametern in Scala
Annotating Konstruktorparameter scheinen nichts zu tun, wenn sie zu Bytecode kompiliert werden. Ich erhalte auch keine Compiler-Warnungen. Die folgenden Arbeiten.getAnnotations für dasname Feld gibt @ zurüjavax.annotation.Nullable. class Person ...
Kann sqlContext.implicits._ nicht ohne Fehler über Jupyter importieren
Wenn ich versuche, das @ zu verwendimport sqlContext.implicits._ Auf meinem Jupyter-Notizbuch wird folgende Fehlermeldung angezeigt: Name: Compile Error Message: <console>:25: error: stable identifier required, but ...
Spark unionAlle mehreren Datenrahmen
Für eine Reihe von Datenrahmen val df1 = sc.parallelize(1 to 4).map(i => (i,i*10)).toDF("id","x") val df2 = sc.parallelize(1 to 4).map(i => (i,i*100)).toDF("id","y") val df3 = sc.parallelize(1 to 4).map(i => (i,i*1000)).toDF("id","z")Union alle ...
Wie berechnet man das Perzentil der Spalte in einem DataFrame im Spark?
Ich versuche, das Perzentil einer Spalte in einem DataFrame zu berechnen. Ich kann keine Percentile_approx-Funktion in Spark-Aggregationsfunktionen finden. Für z.B. in Hive haben wir percentile_approx und wir können es auf folgende Weise ...
Akka HTTPS (SSL) Server mit ssl-conf
Akka Version: Akka 2.4.7 [https://github.com/akka/akka/tree/v2.4.7]Akka Features: HTTPS Server Support [http://doc.akka.io/docs/akka/2.4.7/scala/http/server-side-https-support.html] Typesafe ssl-config ...