统计用户消费金额及占比曲线

eda/feededa/src/main/scala/com/gmei/temp_analysis.scala

@@ -430,8 +430,8 @@ object meigou_xiaofei_renshu {
       sc.sparkContext.addJar("hdfs:///user/hive/share/lib/udf/hive-udf-1.0-SNAPSHOT.jar")
 
 
-      sc.sql("CREATE TEMPORARY FUNCTION dayBitsGetW1 AS 'com.gmei.data.daybits.udf.DayBitsGets$W1'")
-      sc.sql("SELECT order_id FROM mining.ml_order_spam_recognize WHERE partition_date='${partition_date}' AND self_support=0 AND dayBitsGetW1(predict_result,'${partition_date}')=0").show()
+      sc.sql("CREATE TEMPORARY FUNCTION dayBitsGetW1 AS 'com.gmei.data.daybits.udf.DayBitsGetsW1'")
+      sc.sql("SELECT order_id FROM mining.ml_order_spam_recognize WHERE partition_date='20181212' AND self_support=0 AND dayBitsGetW1(predict_result,'20181212')=0").show()
 
 
       import sc.implicits._