新统计指标

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

@@ -14,7 +14,8 @@ object testt {
   Logger.getLogger("org.apache.spark").setLevel(Level.WARN)
   Logger.getLogger("org.apache.eclipse.jetty.server").setLevel(Level.OFF)
 
-  case class Params(env: String = "dev"
+  case class Params(env: String = "dev",
+                    date: String = "2018-08-01"
                    ) extends AbstractParams[Params] with Serializable
 
   val defaultParams = Params()
@@ -24,6 +25,9 @@ object testt {
     opt[String]("env")
       .text(s"the databases environment you used")
       .action((x, c) => c.copy(env = x))
+    opt[String] ("date")
+      .text(s"the date you used")
+      .action((x,c) => c.copy(date = x))
     note(
       """
         |For example, the following command runs this app on a tidb dataset:
@@ -46,7 +50,8 @@ object testt {
       ti.tidbMapTable(dbName = "jerry_prod", tableName = "blacklist")
       ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure")
 
-      val stat_date = GmeiConfig.getMinusNDate(1)
+//      val stat_date = GmeiConfig.getMinusNDate(1)
+      val stat_date=param.date
       val partition_date = stat_date.replace("-","")
       //机构id
       val agency_id = sc.sql(