79590667

Date: 2025-04-24 13:11:26
Score: 2
Natty:
Report link

# Read from SQL table

df = spark.read.table("your_database.source_table")

# Transform: filter age > 25

df_filtered = df.filter(df.age > 25).select("name", "age")

# Write to new SQL table

df_filtered.write.mode("overwrite").saveAsTable("your_database.filtered_table")

Reasons:
  • Low length (0.5):
  • No code block (0.5):
  • Low reputation (1):
Posted by: Kawalpreet Singh