Napraw błędne zapytanie
To zapytanie działa poprawnie, ale w jednym z wierszy zwraca błędny wynik – przyczyną jest pominięcie pewnego elementu w klauzuli OVER. Czy potrafisz znaleźć błąd i zmodyfikować zapytanie tak, żeby dawało prawidłowy wynik?
To ćwiczenie jest częścią kursu
Wprowadzenie do Spark SQL w Pythonie
Instrukcje do ćwiczenia
- Podaj numer błędnego wiersza jako liczbę całkowitą.
- Podaj klauzulę (jako ciąg znaków), której dodanie do klauzuli OVER rozwiązuje problem.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
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 = '____ ____ ____'