Skip to main content
PYSPARK • LESSON 295

Capstone Part 5: Multi-Tier Categorization & Risk Scoring

How can we compute customer transaction risk scores using multi-condition when/otherwise business logic?

Production3 Minutes840 XP
🤔 THE QUESTION

How can we compute customer transaction risk scores using multi-condition when/otherwise business logic?

💡 WHAT IS IT?

Evaluating amount thresholds, user tier, and region simultaneously assigns risk categories (HIGH, MEDIUM, LOW).

🎯 WHAT IS IT USED FOR?

Automated fraud scoring and compliance risk classification in financial engineering.

💻 EXAMPLE
df_scored = df_enriched.withColumn("risk_level", when((col("amount") > 10000) & (col("tier") == "BASIC"), "HIGH").when(col("amount") > 5000, "MEDIUM").otherwise("LOW"))

🎯 Mission Objectives

Practice typing production-grade PySpark code for Capstone Part 5: Multi-Tier Categorization & Risk Scoring.

  • Multi-condition when() scoring
  • Risk tier classification
  • Compliance rule evaluation