年度流量选品-月销默认值填充

Pyspark_job/dwt/dwt_flow_asin_year.py

@@ -302,18 +302,18 @@ class DwtFlowAsinYear(object):
         ).select(
             F.col('asin'),
             F.col('bought_month_total'),
-            F.col('bought_month_1').cast(IntegerType()),
-            F.col('bought_month_2').cast(IntegerType()),
-            F.col('bought_month_3').cast(IntegerType()),
-            F.col('bought_month_4').cast(IntegerType()),
-            F.col('bought_month_5').cast(IntegerType()),
-            F.col('bought_month_6').cast(IntegerType()),
-            F.col('bought_month_7').cast(IntegerType()),
-            F.col('bought_month_8').cast(IntegerType()),
-            F.col('bought_month_9').cast(IntegerType()),
-            F.col('bought_month_10').cast(IntegerType()),
-            F.col('bought_month_11').cast(IntegerType()),
-            F.col('bought_month_12').cast(IntegerType()),
+            F.coalesce(F.col('bought_month_1'), F.lit(0)).cast(IntegerType()).alias('bought_month_1'),
+            F.coalesce(F.col('bought_month_2'), F.lit(0)).cast(IntegerType()).alias('bought_month_2'),
+            F.coalesce(F.col('bought_month_3'), F.lit(0)).cast(IntegerType()).alias('bought_month_3'),
+            F.coalesce(F.col('bought_month_4'), F.lit(0)).cast(IntegerType()).alias('bought_month_4'),
+            F.coalesce(F.col('bought_month_5'), F.lit(0)).cast(IntegerType()).alias('bought_month_5'),
+            F.coalesce(F.col('bought_month_6'), F.lit(0)).cast(IntegerType()).alias('bought_month_6'),
+            F.coalesce(F.col('bought_month_7'), F.lit(0)).cast(IntegerType()).alias('bought_month_7'),
+            F.coalesce(F.col('bought_month_8'), F.lit(0)).cast(IntegerType()).alias('bought_month_8'),
+            F.coalesce(F.col('bought_month_9'), F.lit(0)).cast(IntegerType()).alias('bought_month_9'),
+            F.coalesce(F.col('bought_month_10'), F.lit(0)).cast(IntegerType()).alias('bought_month_10'),
+            F.coalesce(F.col('bought_month_11'), F.lit(0)).cast(IntegerType()).alias('bought_month_11'),
+            F.coalesce(F.col('bought_month_12'), F.lit(0)).cast(IntegerType()).alias('bought_month_12'),
             F.col('bought_month_q1').cast(IntegerType()),
             F.col('bought_month_q2').cast(IntegerType()),
             F.col('bought_month_q3').cast(IntegerType()),