Commit 4745e325 authored by 王志伟's avatar 王志伟

add save file

parent c4b33fe7
......@@ -7,6 +7,7 @@ import org.apache.spark.sql.{SaveMode, TiContext}
import org.apache.log4j.{Level, Logger}
import scopt.OptionParser
import com.gmei.lib.AbstractParams
import java.io._
object temp_analysis {
......@@ -93,6 +94,9 @@ object temp_analysis {
val result = diary_pv.join(meigou_pv,"stat_date")
result.show()
result.select("stat_date","diary_pv","device_num_diary","meigou_pv","device_num_meigou").write.mode(SaveMode.Append).save("/srv/apps/ffm-baseline/eda/feededa/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