转换数据
太好了,现在您终于可以把数据传入您创建的 Pipeline 了!
本练习是课程的一部分
PySpark 基础
练习说明
- 通过链式调用
Pipeline的.fit()和.transform()方法来创建 DataFramepiped_data。这两个方法都只接收model_data作为参数。
交互式实操练习
通过完成这段示例代码来试试这个练习。
# Fit and transform the data
piped_data = flights_pipe.____.____