Commit a8e91e05 by WangJinfeng

update sleep 120s

parent 922920bd
......@@ -46,7 +46,7 @@ class ProcessRTJob extends CommonSparkJob with Serializable {
.rdd.map(row => {
row.getAs[String]("gaid")
}).coalesce(20)
.saveAsTextFile(s"$output/${package_name}", classOf[GzipCodec])
.saveAsTextFile(s"$output/${package_name}/gaid", classOf[GzipCodec])
val map = Logic.getAudienceInfo("lazada")
Logic.writeAudienceInfo("lazada", Logic.getAudienceMap(mutable.HashSet(package_name)))
......
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