Skip to content

F
ffm-baseline
Commit 4df9c820 authored by 高雅喆's avatar 高雅喆
Browse files
Options

drop duplicate

parent eb909ed6
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
eda/feededa/src/main/scala/com/gmei/EsmmData.scala
View file @ 4df9c820
......@@ -588,8 +588,8 @@ object GetDevicePortrait {
val max_count_tag_rdd = max_count_tag.rdd.groupBy(_.getAs[String]("device_id")).map {
case (device_id,data) =>
val stat_date = data.map(_.getAs[String]("stat_date")).head
val max_level1_id = data.map(_.getAs[String]("max_level1_id")).head
val max_level1_count = data.map(_.getAs[String]("max_level1_count")).head
val max_level1_id = data.map(_.getAs[String]("max_level1_id")).head.toString
val max_level1_count = data.map(_.getAs[Long]("max_level1_count")).head.toString
(device_id,stat_date,max_level1_id,max_level1_count)
}.filter(_._1!=null)
......
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