Transformera datan
Nu är du äntligen redo att skicka datan genom den Pipeline du skapade!
Den här övningen är en del av kursen
Grunderna i PySpark
Övningsinstruktioner
- Skapa DataFrame:n
piped_datagenom att anropaPipeline-metoderna.fit()och.transform()i en kedja. Båda metoderna tarmodel_datasom enda argument.
Interaktiv övning med praktiskt arbete
Testa den här övningen genom att slutföra den här exempelkoden.
# Fit and transform the data
piped_data = flights_pipe.____.____