Commit 6a5a9bb2 authored by 王志伟's avatar 王志伟

repair bug

parent bc599e61
...@@ -9,6 +9,8 @@ import scopt.OptionParser ...@@ -9,6 +9,8 @@ import scopt.OptionParser
import com.gmei.lib.AbstractParams import com.gmei.lib.AbstractParams
import java.io._ import java.io._
import org.apache.spark
object app_list { object app_list {
Logger.getLogger("org.apache.spark").setLevel(Level.WARN) Logger.getLogger("org.apache.spark").setLevel(Level.WARN)
...@@ -65,12 +67,13 @@ object app_list { ...@@ -65,12 +67,13 @@ object app_list {
) )
app_list.show() app_list.show()
val appsMapResult=app_list.rdd.map(row=>{ val appsMapResult=app_list.rdd.map(row=>{
println(row)
println(row(1))
}) })
// 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