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
<Kurs>Einführung in Spark SQL mit Python</Kurs>Übungsanweisungen
- 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 praktische Übung
Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.
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 = '____ ____ ____'