周趋势图 增加索引

Pyspark_job/sqoop_export/dim_st_detail_week.py

@@ -164,6 +164,7 @@ if __name__ == '__main__':
 
     trend_sql = f"""
         create table if not exists {trend_export_tb} partition of {trend_master_tb} for values from ('{year_str}') to ('{trend_year_next}');
+        create index if not exists {trend_export_tb}_st_key_idx on {trend_export_tb} using btree (st_key);
         delete from {trend_export_tb} where date_info = '{date_info}';
     """
     DBUtil.engine_exec_sql(engine, trend_sql)