修改rdd

e24c3cb0 · 张彦钊 · a229ac06 · e24c3cb0
Commit e24c3cb0 authored Dec 07, 2018 by 张彦钊
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

Data2FFM.scala eda/feededa/src/main/scala/com/gmei/Data2FFM.scala +1 -1

No files found.
--- a/eda/feededa/src/main/scala/com/gmei/Data2FFM.scala
+++ b/eda/feededa/src/main/scala/com/gmei/Data2FFM.scala
@@ -56,7 +56,7 @@ object Data2FFM {
      val esmm_data = sc.sql(
        s"""
           |select device_id,y,z,stat_date,ucity_id,cid_id,clevel1_id,ccity_name
-           |from esmm_train_data
+           |from esmm_train_data limit 6
         """.stripMargin
      ).na.drop()
      val column_list = esmm_data.columns