Commit 911ca92ac25981df592915a27cfea2910555ce94
1 parent
34d9c2c35a
Exists in
master
filesave true
Showing 1 changed file with 1 additions and 1 deletions Side-by-side Diff
app/com/piki_ds/ver1/EditorScore.scala
View file @
911ca92
| ... | ... | @@ -67,7 +67,7 @@ |
| 67 | 67 | val user_info: RDD[(String, String)] = user_tableGet.map(x=>(x.getAs[Long]("uid").toString, x.getAs[String]("name"))) |
| 68 | 68 | |
| 69 | 69 | // DB에서 FOLLOW table 파싱해오기, 팔로워 수 가져오기 |
| 70 | - val follow_info: RDD[(String, Long)] = followGetter(sQLContext, dateKey, false) | |
| 70 | + val follow_info: RDD[(String, Long)] = followGetter(sQLContext, dateKey) | |
| 71 | 71 | |
| 72 | 72 | val joinedFollowInfo: RDD[(String, (String, Long))] = user_info.leftOuterJoin(follow_info).map(x=>(x._1,(x._2._1,x._2._2.getOrElse(10L)))) |
| 73 | 73 |