Ingénierie des caractéristiques avec PySpark
John Hogue
Lead Data Scientist

Multiplier
Additionner
Différencier
Diviser


Multiplication
# Creating a new feature, area by multiplying
df = df.withColumn('TSQFT', (df['WIDTH'] * df['LENGTH']))

# Sum two columns
df = df.withColumn('TSQFT', (df['SQFTBELOWGROUND'] + df['SQFTABOVEGROUND']))
# Divide two columns
df = df.withColumn('PRICEPERTSQFT', (df['LISTPRICE'] / df['TSQFT']))
# Difference two columns
df = df.withColumn('DAYSONMARKET', datediff('OFFMARKETDATE', 'LISTDATE'))
Automatisation des caractéristiques

Ingénierie des caractéristiques avec PySpark