Menggabungkan kolom

Tahap akhir dari penyiapan data adalah mengonsolidasikan semua kolom prediktor ke dalam satu kolom.

Versi terbaru dari data flights, yang sudah mencakup semua perubahan dari beberapa latihan sebelumnya, memiliki kolom prediktor berikut:

mon, dom, dan dow
carrier_idx (nilai yang diindeks dari carrier)
org_idx (nilai yang diindeks dari org)
km
depart
duration

Catatan: Argumen truncate=False pada metode show() mencegah data terpotong pada keluaran.

Latihan ini merupakan bagian dari kursus

Machine Learning dengan PySpark

Lihat Kursus

Instruksi latihan

Impor kelas yang akan merakit kolom prediktor.
Buat objek assembler yang memungkinkan Anda menggabungkan kolom prediktor menjadi satu kolom.
Gunakan assembler untuk menghasilkan kolom konsolidasi yang baru.

Latihan interaktif langsung praktik

Cobalah latihan ini dengan melengkapi kode contoh ini.

# Import the necessary class
from pyspark.ml.feature import ____

# Create an assembler object
assembler = ____(inputCols=[
    ____
], outputCol='features')

# Consolidate predictor columns
flights_assembled = assembler.____(____)

# Check the resulting column
flights_assembled.select('features', 'delay').show(5, truncate=False)

Edit dan Jalankan Kode