Skip to content

F
ffm-baseline
Commit bc599e61 authored by 王志伟's avatar 王志伟
Browse files
Options

repair bug

parent 70fc31a5
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 8 deletions
eda/feededa/src/main/scala/com/gmei/app_list.scala
View file @ bc599e61
...@@ -65,16 +65,9 @@ object app_list { ...@@ -65,16 +65,9 @@ object app_list {
) )
app_list.show() app_list.show()
val appsMapResult=app_list.rdd.map(row=>{ val appsMapResult=app_list.rdd.map(row=>{
val rowAppFieldMap:Map[String,Any] = row.getAs[Map[String,Any]]("app_list") println(row)
if (rowAppFieldMap.nonEmpty){
if (rowAppFieldMap.contains("更美")){
if (rowAppFieldMap.contains("新氧美容")){
return println(rowAppFieldMap)
}
}
}
}) })
// result.select("stat_date","diary_pv","device_num_diary","meigou_pv","device_num_meigou").write.mode(SaveMode.Append).save("/data2/test.txt") // result.select("stat_date","diary_pv","device_num_diary","meigou_pv","device_num_meigou").write.mode(SaveMode.Append).save("/data2/test.txt")
......
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