开始使用免费开始使用

修复错误查询

此查询可以正确运行,但由于 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 = '____ ____ ____'
编辑并运行代码