修复错误查询
此查询可以正确运行,但由于 OVER 子句中遗漏了一部分,其中一行的结果不正确。您能找到这个错误吗?您能修改查询,让它返回一个合理的结果吗?
本练习是课程的一部分
Python 中的 Spark SQL 入门
练习说明
- 将出错行的行号以整数形式提供。
- 提供一个子句(字符串形式),把它添加到 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 = '____ ____ ____'