Die fehlerhafte Abfrage beheben
Diese Abfrage läuft zwar fehlerfrei, liefert aber in einer der Zeilen ein falsches Ergebnis, weil in der OVER-Klausel etwas fehlt. Kannst du den Fehler finden? Kannst du die Abfrage so ändern, dass sie ein sinnvolles Ergebnis liefert?
Diese Übung ist Teil des Kurses
Einführung in Spark SQL mit Python
Anleitung zur Übung
- Gib die Zeilennummer der fehlerhaften Zeile als ganze Zahl an.
- Gib die Klausel (als String) an, die beim Hinzufügen zur OVER-Klausel das Problem behebt.
Interaktive Übung
Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.
query = """
SELECT
ROW_NUMBER() OVER (ORDER BY time) AS row,
train_id,
station,
time,
LEAD(time,1) OVER (ORDER BY time) AS time_next
FROM schedule
"""
spark.sql(query).show()
# Give the number of the bad row as an integer
bad_row = ____
# Provide the missing clause, SQL keywords in upper case
clause = '____ ____ ____'