diff --git a/bootcamp/materials/3-spark-fundamentals/src/jobs/team_vertex_job.py b/bootcamp/materials/3-spark-fundamentals/src/jobs/team_vertex_job.py index 92c9c28c..ae47cfb8 100644 --- a/bootcamp/materials/3-spark-fundamentals/src/jobs/team_vertex_job.py +++ b/bootcamp/materials/3-spark-fundamentals/src/jobs/team_vertex_job.py @@ -34,3 +34,4 @@ def main(): .getOrCreate() output_df = do_team_vertex_transformation(spark, spark.table("players")) output_df.write.mode("overwrite").insertInto("players_scd") + output_df.write.mode("overwrite").insertInto("team_vertex")