重新跑指标

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

@@ -61,6 +61,12 @@ object testt {
       )
       blacklist.createOrReplaceTempView("blacklist")
 
+      sc.sql("ADD JAR hdfs:///user/hive/share/lib/udf/brickhouse-0.7.1-SNAPSHOT.jar")
+      sc.sql("ADD JAR hdfs:///user/hive/share/lib/udf/hive-udf-1.0-SNAPSHOT.jar")
+      sc.sql("CREATE TEMPORARY FUNCTION json_map AS 'brickhouse.udf.json.JsonMapUDF'")
+      sc.sql("CREATE TEMPORARY FUNCTION is_json AS 'com.gmei.hive.common.udf.UDFJsonFormatCheck'")
+
+
       val agency_id = sc.sql(
         s"""
            |SELECT DISTINCT(cl_id) as device_id
@@ -458,6 +464,12 @@ object diary_clk_card {
 //      val stat_date=param.date
       val partition_date = stat_date.replace("-","")
       //机构id
+
+      sc.sql("ADD JAR hdfs:///user/hive/share/lib/udf/brickhouse-0.7.1-SNAPSHOT.jar")
+      sc.sql("ADD JAR hdfs:///user/hive/share/lib/udf/hive-udf-1.0-SNAPSHOT.jar")
+      sc.sql("CREATE TEMPORARY FUNCTION json_map AS 'brickhouse.udf.json.JsonMapUDF'")
+      sc.sql("CREATE TEMPORARY FUNCTION is_json AS 'com.gmei.hive.common.udf.UDFJsonFormatCheck'")
+
       val blacklist = sc.sql(
         s"""
            |select device_id from blacklist