Commit 438f843a authored by 宋柯's avatar 宋柯

降配

parent c3b895c6
...@@ -203,7 +203,7 @@ group by partition_date ...@@ -203,7 +203,7 @@ group by partition_date
""".format(START_PARTITION_DATE,START_PARTITION_DATE,START_PARTITION_DATE) """.format(START_PARTITION_DATE,START_PARTITION_DATE,START_PARTITION_DATE)
spark_df = spark.sql(HIVE_SQL) spark_df = spark.sql(HIVE_SQL)
spark_df.show(100,False) # spark_df.show(100,False)
pandas_df = spark_df.toPandas() pandas_df = spark_df.toPandas()
pandas_df.fillna(0,inplace=True) pandas_df.fillna(0,inplace=True)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment