Skip to content

Commit 6c020d8

Browse files
Update team_vertex_job.py
1 parent 305d0c4 commit 6c020d8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

bootcamp/materials/3-spark-fundamentals/src/jobs/team_vertex_job.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,4 +33,4 @@ def main():
3333
.appName("players_scd") \
3434
.getOrCreate()
3535
output_df = do_team_vertex_transformation(spark, spark.table("players"))
36-
output_df.write.mode("overwrite").insertInto("players_scd")
36+
output_df.write.mode("overwrite").insertInto("team_vertex")

0 commit comments

Comments
 (0)