Corrige la consulta rota
Esta consulta se ejecuta correctamente, pero devuelve un resultado incorrecto en una de las filas por una omisión en la cláusula OVER. ¿Puedes localizar el error? ¿Puedes modificar la consulta para que devuelva un resultado razonable?
Este ejercicio forma parte del curso
Introducción a Spark SQL en Python
Instrucciones del ejercicio
- Indica el número de la fila errónea como un entero.
- Proporciona la cláusula (como cadena) que, al añadirse a la cláusula OVER, soluciona el problema.
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
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 = '____ ____ ____'