Corrigir a consulta com erro
Esta consulta é executada corretamente, mas retorna um resultado incorreto em uma das linhas por causa de uma omissão na cláusula OVER. Você consegue localizar o erro? Consegue modificar a consulta para produzir um resultado razoável?
Este exercício faz parte do curso
Introdução ao Spark SQL em Python
Instruções do exercício
- Forneça o número da linha incorreta como um inteiro.
- Forneça a cláusula (como uma string) que, ao ser adicionada à cláusula OVER, corrige o problema.
Exercício interativo prático
Experimente este exercício completando este código de exemplo.
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 = '____ ____ ____'