Suchergebnisse für Anfrage "window-functions"
Spark und SparkSQL: Wie kann man die Fensterfunktion imitieren?
BeschreibunGab einen Datenrahmendf id | date --------------- 1 | 2015-09-01 2 | 2015-09-01 1 | 2015-09-03 1 | 2015-09-04 2 | 2015-09-04Ich möchte einen laufenden Zähler oder Index erstellen, gruppiert mit der gleichen ID undsortiert nach Datum ...
SparkSQL - Lag-Funktion?
Ich sehe in diesemDataBricks post [https://databricks.com/blog/2015/07/15/introducing-window-functions-in-spark-sql.html] , in SparkSql werden Fensterfunktionen unterstützt, insbesondere versuche ich, die Fensterfunktion lag () zu verwenden. Ich ...
Crosstab-Funktion in Postgres, die eine Ausgabe mit einer Zeile zurückgibt, wenn ich mehrere Zeilen erwarte
Ich habe derzeit einen Tischm mit folgendem Format: id scenario period ct 2 1 1 1 2 1 2 1 2 1 3 1 2 1 4 1 2 2 1 1 2 2 2 1 2 2 3 1 2 2 4 1 2 3 1 1 2 3 2 1 2 3 3 1 2 3 4 1Ich möchte die folgende Tabelle erstellen: id scenario period 1 2 3 4 2 1 1 ...
Spark-Fensterfunktionen - BereichZwischen Datumsangaben
Ich habe einen Spark SQLDataFrame mit Daten und was ich versuche zu erhalten, ist alle Zeilen vor der aktuellen Zeile in einem bestimmten Datumsbereich. So möchte ich zum Beispiel alle Zeilen ab 7 Tagen vor der angegebenen Zeile haben. Ich habe ...
Oracle Lag Funktion mit dynamischem Parameter
Ich habe ein bestimmtes Problem. Ich habe eine Tabelle, die ungültige Werte enthält. Ich muss die ungültigen Werte ersetzen (hier0) mit dem vorherigen Wert, der größer als @ i0. Die Schwierigkeit ist, dass ich kein Update oder keine Einfügung ...
Running Summe über wiederholte Gruppierung nach Elementen basierend auf der Zeit in Oracle SQL
Mein erster Beitrag, also trage mich. Ich möchte die Summe basierend auf einem Wert erstellen, der nach Datumsangaben unterteilt ist, möchte jedoch nur die Summe für die Datumsangaben, nicht für die Gruppe nach Element insgesamt. Ich habe seit ...
Apache Spark Window-Funktion mit verschachtelter Spalte
Ich bin mir nicht sicher, ob dies ein Fehler ist (oder nur eine falsche Syntax). Ich habe mich umgesehen und habe dies an keiner anderen Stelle erwähnt. Deshalb frage ich hier, bevor ich einen Fehlerbericht einreiche. Ich versuche, eine ...
First_value Fensterfunktion in Pyspark
Ich benutze Pyspark 1.5, um meine Daten aus Hive-Tabellen abzurufen und versuche, Fensterfunktionen zu verwenden. GemäßDie [https://databricks.com/blog/2015/07/15/introducing-window-functions-in-spark-sql.html] gibt es eine analytische ...
Wie kann man das Ausführen von SUM "zurücksetzen", nachdem es einen Schwellenwert erreicht hat?
Ich habe eine Abfrage geschrieben, die zwei Spalten erstellt:the_day, und dieamount_raised an diesem Tag. Folgendes habe ich: [/imgs/SlNQH.png] Und ich möchte eine Spalte hinzufügen, die eine laufende Summe von @ hamount_raised: ...
Verwenden von Fensterfunktionen in Spark
Ich versuche, rowNumber in Spark-Datenrahmen zu verwenden. Meine Abfragen funktionieren erwartungsgemäß in der Spark-Shell. Aber wenn ich sie in Eclipse ausschreibe und ein Glas kompiliere, stoße ich auf einen Fehler 16/03/23 05:52:43 ERROR ...