PySpark ile Özellik Mühendisliği
John Hogue
Lead Data Scientist, General Mills
Veri Toplama
Veri Depolama Kuralları
Farklı Verileri Birleştirme
Kasıtlı Olarak Eksik

Tamamen rastgele eksik
Rastgele eksik
Rastgele olmayan eksik
Eksik verili satırları ne zaman düşürmeli?
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())

Eksik değerleri doldurma süreci
Kural Tabanlı
İstatistik Tabanlı
Model Tabanlı
** fillna(value, subset=None)
value eksikleri hangi değerle değiştireceğinsubset eksikleri değiştirilecek sütun adları listesi# Eksik değerleri sıfırla değiştirme
df.fillna(0, subset=['DAYSONMARKET'])
# Sütunun ortalamasıyla değiştirme
col_mean = df.agg({'DAYSONMARKET': 'mean'}).collect()[0][0]
df.fillna(col_mean, subset=['DAYSONMARKET'])
PySpark ile Özellik Mühendisliği