Commit a7900b4e32550a9ef104f755168c11edef5f3792
1 parent
042a099d3f
Exists in
master
back to ggh ver 1
Showing 1 changed file with 1 additions and 1 deletions Side-by-side Diff
app/com/piki_ds/ver1/ContentScore.scala
View file @
a7900b4
| ... | ... | @@ -40,7 +40,7 @@ |
| 40 | 40 | val conDwell: RDD[(Int, Map[String, Int])] = TempScoreSaveLoad.scoreLoad(sc,doi,"content","dwell").repartition(10).map(x=>(x._1,Map("cid"->x._1,"dwell"->x._2))) |
| 41 | 41 | val conPostAction: RDD[(Int, Map[String, Int])] = TempScoreSaveLoad.scoreLoad(sc,doi,"content","postAction").repartition(10).map(x=>(x._1,Map("cid"->x._1,"postAction"->x._2))) |
| 42 | 42 | val conReject: RDD[(Int, Map[String, Int])] = TempScoreSaveLoad.scoreLoad(sc,doi,"content","reject").repartition(10).map(x=>(x._1,Map("cid"->x._1,"reject"->x._2))) |
| 43 | - val conEfficiency: RDD[(Int, Map[String, Int])] = TempScoreSaveLoad.scoreLoad(sc,doi,"content","ggh").repartition(10).map(x=>(x._1,Map("cid"->x._1,"efficiency"->x._2))) | |
| 43 | + val conEfficiency: RDD[(Int, Map[String, Int])] = TempScoreSaveLoad.scoreLoad(sc,doi,"content","efficiency").repartition(10).map(x=>(x._1,Map("cid"->x._1,"efficiency"->x._2))) | |
| 44 | 44 | |
| 45 | 45 | val conScores = Array(conClick,conDwell,conPostAction,conReject,conEfficiency) |
| 46 | 46 |