Spark 2 Workbook Answers May 2026

# 2️⃣ Split lines into words and clean them words = lines.flatMap(lambda line: line.split()) \ .map(lambda w: w.lower().strip('.,!?"\''))

val result = df .groupBy($"department") .agg(count("*").as("emp_cnt"), avg($"salary").as("avg_salary")) .filter($"emp_cnt" > 5) spark 2 workbook answers

def fetch_batch(it): session = requests.Session() for url in it: yield session.get(url).text session.close() # 2️⃣ Split lines into words and clean