列操作
美国联邦航空管理局(FAA)将航班到达时间比计划晚 15 分钟或更久定义为"延误"。
准备航班数据的下一步包括两部分:
- 将距离单位转换为公里,用
km列替换mile列;以及 - 创建一个布尔列,用于指示航班是否延误。
本练习是课程的一部分
使用 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)