Åtgärda den trasiga frågan
Den här frågan körs utan fel, men ger ett felaktigt resultat i en av raderna på grund av ett utelämnat element i OVER-satsen. Kan du hitta felet? Kan du ändra frågan så att den ger ett rimligt resultat?
Den här övningen är en del av kursen
Introduktion till Spark SQL i Python
Övningsinstruktioner
- Ange radnumret för den felaktiga raden som ett heltal.
- Ange satsen (som en sträng) som, när den läggs till i OVER-satsen, åtgärdar problemet.
Interaktiv övning med praktiskt arbete
Testa den här övningen genom att slutföra den här exempelkoden.
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 = '____ ____ ____'