Commit 0a0e3068 authored by 王志伟's avatar 王志伟

repair bug

parent e2e563b0
......@@ -13,8 +13,7 @@ object Recommendation_strategy_all {
Logger.getLogger("org.apache.spark").setLevel(Level.WARN)
Logger.getLogger("org.apache.eclipse.jetty.server").setLevel(Level.OFF)
case class Params(env: String = "dev",
date: String = "2018-08-01"
case class Params(env: String = "dev"
) extends AbstractParams[Params] with Serializable
val defaultParams = Params()
......@@ -24,9 +23,6 @@ object Recommendation_strategy_all {
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:
......@@ -54,6 +50,7 @@ object Recommendation_strategy_all {
import sc.implicits._
val stat_date = GmeiConfig.getMinusNDate(1)
println(stat_date)
//println(param.date)
val partition_date = stat_date.replace("-","")
val decive_id_oldUser = sc.sql(
......
......@@ -54,7 +54,6 @@ object testt {
|from online.tl_hdfs_maidian_view
|where action="page_view"
|and params["page_name"]="diary_detail"
|and (params["out"]-params["in"])<7200
|and partition_date >='20180901'
""".stripMargin
)
......
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