Feature Engineering với PySpark
John Hogue
Lead Data Scientist

Nhân
Cộng
Lấy hiệu
Chia


Phép nhân
# Tạo đặc trưng mới: diện tích bằng phép nhân
df = df.withColumn('TSQFT', (df['WIDTH'] * df['LENGTH']))

# Cộng hai cột
df = df.withColumn('TSQFT', (df['SQFTBELOWGROUND'] + df['SQFTABOVEGROUND']))
# Chia hai cột
df = df.withColumn('PRICEPERTSQFT', (df['LISTPRICE'] / df['TSQFT']))
# Lấy hiệu hai cột
df = df.withColumn('DAYSONMARKET', datediff('OFFMARKETDATE', 'LISTDATE'))
Tự động hóa đặc trưng

Feature Engineering với PySpark