Commit 5ee0858f8953a5b4320fa0865777efd6f37ba0d4

Authored by Joanne ago
1 parent 6f482f9718
Exists in master

add ggh2 to contnet score

Showing 1 changed file with 2 additions and 2 deletions Side-by-side Diff

app/com/piki_ds/ver1/ContentScore.scala View file @ 5ee0858
... ... @@ -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","efficiency").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","ggh").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  
... ... @@ -57,7 +57,7 @@
57 57 val cidOfInterest: RDD[(Long, (Int, Long))] = getCidByStatus(sqlContext, Array("ACTV","HOLD"))
58 58  
59 59 val cidAndScoreFormatted = make_0to1(contentScore.map(x=> (x._1,x._2.toDouble))).map(x=>(x._1, (x._2*1000).toLong))
60   - TempScoreSaveLoad.scoreSave(doi,"content","all",cidAndScoreFormatted,1)
  60 + TempScoreSaveLoad.scoreSave(doi,"content","all_ver2",cidAndScoreFormatted,1)
61 61 }
62 62  
63 63 }