开始使用免费开始使用

列操作

美国联邦航空管理局(FAA)将航班到达时间比计划晚 15 分钟或更久定义为"延误"。

准备航班数据的下一步包括两部分:

  1. 将距离单位转换为公里,用 km 列替换 mile 列;以及
  2. 创建一个布尔列,用于指示航班是否延误。

本练习是课程的一部分

使用 PySpark 进行机器学习

查看课程

练习说明

  • 导入一个函数,用于将数字四舍五入到指定小数位。
  • mile 列派生新的 km 列,并四舍五入到 0 位小数。1 英里等于 1.60934 公里。
  • 删除 mile 列。
  • 创建 label 列:延误时间达到或超过 15 分钟记为 1,否则记为 0。请仔细思考逻辑条件。

交互式实操练习

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

# Import the required function
from pyspark.sql.functions import ____

# Convert 'mile' to 'km' and drop 'mile' column (1 mile is equivalent to 1.60934 km)
flights_km = flights.____('km', ____(____ * ____, 0)) \
                    .____('mile')

# Create 'label' column indicating whether flight delayed (1) or not (0)
flights_km = flights_km.____('label', (____).cast('integer'))

# Check first five records
flights_km.show(5)
编辑并运行代码