Преобразование данных
Отлично, теперь вы наконец готовы передать данные через созданный вами Pipeline!
Это упражнение является частью курса
Основы PySpark
Инструкции к упражнению
- Создайте DataFrame
piped_data, последовательно вызвав методы.fit()и.transform()объектаPipeline. Оба метода принимаютmodel_dataв качестве единственного аргумента.
Интерактивное практическое упражнение
Попробуйте выполнить это упражнение, дополнив этот пример кода.
# Fit and transform the data
piped_data = flights_pipe.____.____