File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
1-dimensional-data-modeling/sql
3-spark-fundamentals/src/jobs Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change 65
65
ELSE ' bad'
66
66
END::scoring_class AS scoring_class,
67
67
w .season - (seasons[CARDINALITY(seasons)]::season_stats).season as years_since_last_active,
68
- w .season ,
69
- (seasons[CARDINALITY(seasons)]::season_stats) .season = season AS is_active
68
+ (seasons[CARDINALITY(seasons)]::season_stats) .season = season AS is_active ,
69
+ w .season
70
70
FROM windowed w
71
71
JOIN static s
72
- ON w .player_name = s .player_name ;
72
+ ON w .player_name = s .player_name ;
Original file line number Diff line number Diff line change @@ -33,4 +33,4 @@ def main():
33
33
.appName ("players_scd" ) \
34
34
.getOrCreate ()
35
35
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 " )
You can’t perform that action at this time.
0 commit comments