Tổng hợp II
Để bạn làm quen thêm với các phương thức tổng hợp dựng sẵn, dưới đây là một vài bài tập nữa với bảng flights!
Hãy nhớ, một SparkSession tên là spark đã có sẵn trong không gian làm việc của bạn, cùng với Spark DataFrame flights.
Bài tập này là một phần của khóa học
Nền tảng về PySpark
Hướng dẫn bài tập
- Dùng phương thức
.avg()để lấy thời gian bay trung bình của các chuyến bay Delta Airlines (nơi cộtcarriercó giá trị"DL") khởi hành từ SEA. Nơi khởi hành được lưu trong cộtorigin.show()kết quả. - Dùng phương thức
.sum()để tính tổng số giờ tất cả máy bay trong tập dữ liệu này đã bay, bằng cách tạo một cột tênduration_hrstừ cộtair_time.show()kết quả.
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.
# Average duration of Delta flights
flights.filter(____.____ == "____").filter(____.____ == "____").groupBy().avg("____").show()
# Total hours in the air
flights.withColumn("____", flights.air_time/60).groupBy().sum("____").show()