Przekształć dane
Świetnie, czas przekazać dane przez utworzony przez ciebie obiekt Pipeline!
To ćwiczenie jest częścią kursu
Podstawy PySpark
Instrukcje do ćwiczenia
- Utwórz DataFrame
piped_data, wywołując metody.fit()i.transform()obiektuPipelinew łańcuchu. Obie te metody przyjmująmodel_datajako jedyny argument.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
# Fit and transform the data
piped_data = flights_pipe.____.____