Vytvoření pipeline
Teď už jsi připraven/a vytvořit Pipeline!
Pipeline je třída z modulu pyspark.ml, která spojuje všechny Estimators a Transformers, které jsi zatím vytvořil/a. Díky tomu můžeš celý proces modelování znovu a znovu používat — stačí ho zabalit do jednoho jednoduchého objektu. Šikovné, že?
Toto cvičení je součástí kurzu
Foundations of PySpark
Pokyny k cvičení
- Importuj
Pipelinezpyspark.ml. - Zavolej konstruktor
Pipeline()s pojmenovaným argumentemstagesa vytvoř takPipelines názvemflights_pipe.stagesby měl být seznam obsahující všechny kroky, kterými mají tvoje data v pipeline projít. V tomto případě jde o:[dest_indexer, dest_encoder, carr_indexer, carr_encoder, vec_assembler]
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
# Import Pipeline
from ____ import ____
# Make the pipeline
flights_pipe = Pipeline(stages=____)