Sửa truy vấn bị lỗi
Truy vấn này chạy không lỗi, nhưng trả về kết quả không đúng ở một hàng do thiếu sót trong mệnh đề OVER. Bạn có thể tìm ra lỗi không? Bạn có thể chỉnh sửa truy vấn để cho ra kết quả hợp lý không?
Bài tập này là một phần của khóa học
Nhập môn Spark SQL bằng Python
Hướng dẫn bài tập
- Cung cấp số thứ tự của hàng lỗi dưới dạng số nguyên.
- Cung cấp mệnh đề (dưới dạng chuỗi) mà khi thêm vào mệnh đề OVER sẽ khắc phục vấn đề.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
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 = '____ ____ ____'