Add a New Column in PySpark | Dataford Interview Questions

How do you add a new column to a DataFrame in PySpark?

Asked in the Technical - PySpark stage.

Write the answer as if you are modifying a DataFrame that already contains employee payroll data. Show how to create one additional column derived from existing fields.

Output

One updated DataFrame with the new column included
The new column should be named annual_bonus
Preserve all existing rows and columns

Schema

employee_payroll

Column	Type	Description
employee_idPK	INT	Unique employee identifier
employee_name	VARCHAR(100)	Employee full name
department	VARCHAR(50)	Employee department
monthly_salary	DECIMAL(10,2)	Monthly salary amount

Your question is Add a New Column in PySpark. Start with the requirements and the one table in the Question tab.

Run and submit as often as you like. When you're ready, talk me through your approach or go straight to the code.

Problem