壊れたクエリを修正する
このクエリは実行自体は成功しますが、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 = '____ ____ ____'