Commit 0c4bd1db authored by 宋柯's avatar 宋柯

模型bug修复

parent a76c134e
...@@ -983,7 +983,7 @@ if __name__ == '__main__': ...@@ -983,7 +983,7 @@ if __name__ == '__main__':
return res return res
itemStatisticDF = itemStatisticDF.rdd.flatMap(splitPatitionDatasFlatMapFunc).toDF(["card_id", "partition_date", "label", "label_count"]) itemStatisticDF = itemStatisticDF.rdd.flatMap(splitPatitionDatasFlatMapFunc).toDF(["card_id", "partition_date", "label", "label_count"])
itemStatisticDF.show(1000, False) itemStatisticDF.orderBy(['card_id', 'label', 'partition_date']).show(1000, False)
sys.exit(1) sys.exit(1)
clickDF = spark.sql(clickSql) clickDF = spark.sql(clickSql)
clickDF.createOrReplaceTempView("clickDF") clickDF.createOrReplaceTempView("clickDF")
......
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