Исправьте неверный запрос
Этот запрос выполняется без ошибок, однако в одной из строк возвращает неверный результат из-за пропуска в предложении OVER. Найдите ошибку и измените запрос так, чтобы он возвращал корректный результат.
Это упражнение является частью курса
Введение в Spark SQL на Python
Инструкции к упражнению
- Укажите номер ошибочной строки как целое число.
- Укажите предложение (в виде строки), которое нужно добавить в OVER, чтобы устранить проблему.
Интерактивное практическое упражнение
Попробуйте выполнить это упражнение, дополнив этот пример кода.
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 = '____ ____ ____'