diff --git a/scripts/medium/medium-stats-spark-driver.py b/scripts/medium/medium-stats-spark-driver.py index 18767ad..1b85581 100644 --- a/scripts/medium/medium-stats-spark-driver.py +++ b/scripts/medium/medium-stats-spark-driver.py @@ -193,7 +193,8 @@ def compute_yearly_statistics(spark, table_name): help="Ingestion mode: append or create", ) args = parser.parse_args() - + + catalog_name = "medium_stats" db_name = "mediumstats" table_name = "articles" local_path = "/usr/stats/" + args.key