开始使用免费开始使用

聚合 II

为帮助您熟悉更多内置聚合方法,这里提供一些关于 flights 表的练习!

请记住,名为 sparkSparkSession 已在您的工作区中,同时还有 Spark DataFrame flights

本练习是课程的一部分

PySpark 基础

查看课程

练习说明

  • 使用 .avg() 方法获取从 SEA 出发、由达美航空执飞(carrier 列取值为 "DL")航班的平均空中飞行时间。出发地存储在 origin 列中。使用 show() 显示结果。
  • 使用 .sum() 方法,通过从 air_time 列创建名为 duration_hrs 的列,计算此数据集中所有飞机在空中的总小时数。使用 show() 显示结果。

交互式实操练习

通过完成这段示例代码来试试这个练习。

# 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()
编辑并运行代码