Commit f815d04efedecde00ff161c27d2c470da6bf27eb
1 parent
9777b48db5
Exists in
master
hbase url send
Showing 1 changed file with 1 additions and 1 deletions Side-by-side Diff
app/com/piki_ds/ver1/EditorScore.scala
View file @
f815d04
... | ... | @@ -165,7 +165,7 @@ |
165 | 165 | val formatOutput: RDD[(String, Long)] = finalScore.map(x=>(x._1,(x._2*1000).toLong)) |
166 | 166 | |
167 | 167 | TempScoreSaveLoad.scoreSave(dateKey,"editor","",formatOutput,1) |
168 | - scala.io.Source.fromURL(s"http://hbase.api.piki.work:9081/insert?table=editor_score&path=hdfs://pikinn/preprocess/timelineScore/editor/$dateKey") | |
168 | + scala.io.Source.fromURL(s"http://hbase.api.piki.work:9081/insert?table=editor_score&path=/preprocess/timelineScore/editor/$dateKey") | |
169 | 169 | /* |
170 | 170 | val insertArray: Array[(String, String)] = finalScore.map(x=>(x._1.toString, (x._2*1000).toLong.toString)).collect |
171 | 171 | val test = new HbaseInserter("editor_score") |