Rekayasa Fitur dengan PySpark
John Hogue
Lead Data Scientist, General Mills
Pengumpulan Data
Aturan Penyimpanan Data
Menggabungkan Data yang Berbeda
Sengaja Dikosongkan

Hilang sepenuhnya acak
Hilang acak
Tidak hilang acak
Kapan baris dengan data hilang dihapus?
isNull()
df.where(df['ROOF'].isNull()).count()
765
# Import library import seaborn as sns# subset the dataframe sub_df = df.select(['ROOMAREA1'])# sample the dataframe sample_df = sub_df.sample(False, .5, 4)# Convert to Pandas DataFrame pandas_df = sample_df.toPandas()# Plot it sns.heatmap(data=pandas_df.isnull())

Proses mengganti nilai hilang
Berbasis Aturan
Berbasis Statistik
Berbasis Model
** fillna(value, subset=None)
value nilai pengganti untuk yang hilangsubset daftar nama kolom yang akan diganti nilainya# Mengganti nilai hilang dengan nol
df.fillna(0, subset=['DAYSONMARKET'])
# Mengganti dengan nilai mean kolom tersebut
col_mean = df.agg({'DAYSONMARKET': 'mean'}).collect()[0][0]
df.fillna(col_mean, subset=['DAYSONMARKET'])
Rekayasa Fitur dengan PySpark