Tạo pipeline
Giờ thì bạn đã sẵn sàng tạo một Pipeline rồi!
Pipeline là một lớp trong mô-đun pyspark.ml dùng để kết hợp tất cả Estimator và Transformer mà bạn đã tạo. Cách này giúp bạn tái sử dụng cùng một quy trình mô hình hóa nhiều lần bằng cách gói gọn nó trong một đối tượng đơn giản. Thật tiện lợi, đúng không?
Bài tập này là một phần của khóa học
Nền tảng về PySpark
Hướng dẫn bài tập
- Import
Pipelinetừpyspark.ml. - Gọi hàm tạo
Pipeline()với tham số tênstagesđể tạo mộtPipelinetên làflights_pipe.stagesnên là một danh sách chứa tất cả các bước bạn muốn dữ liệu đi qua trong pipeline. Ở đây chỉ gồm:[dest_indexer, dest_encoder, carr_indexer, carr_encoder, vec_assembler]
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
# Import Pipeline
from ____ import ____
# Make the pipeline
flights_pipe = Pipeline(stages=____)