许家凯 4 anos atrás
pai
commit
c7ea469bc6

+ 1 - 4
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/CompanyDynamic.scala

@@ -74,7 +74,7 @@ object CompanyDynamic {
         val old_data = r.getAs[Map[String, String]]("old_data")
         val biz_date = r.getAs[String]("biz_date")
         val fields = r.getAs[String]("fields")
-        val res = handle.handle(rowkey, biz_date, cid, if(fields==null) null else fields.split(","), old_data, new_data)
+        val res = handle.handle(rowkey, biz_date, cid, if (fields == null) null else fields.split(","), old_data, new_data)
         Row(cid, res._1, res._2, res._3, res._4, res._5, res._6, res._7, res._8, DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"))
       })
 
@@ -110,10 +110,7 @@ object CompanyDynamic {
            |FROM
            |    company_dynamic_tmp
            |""".stripMargin)
-
     }
-
-
   }