聚合 II
为帮助您熟悉更多内置聚合方法,这里提供一些关于 flights 表的练习!
请记住,名为 spark 的 SparkSession 已在您的工作区中,同时还有 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()