Commit 0c319c0d6bb75332e7722509e3d6806c705d97fa
1 parent
0a5c9fb1f6
Exists in
master
변수 분포 조정을 위한 파라미터 변경
Showing 1 changed file with 2 additions and 2 deletions Side-by-side Diff
app/com/piki_ds/utils/GeneralTransformers.scala
View file @
0c319c0
| ... | ... | @@ -24,7 +24,7 @@ |
| 24 | 24 | * @param rawInp: RDD[(key, value to be transformed)] |
| 25 | 25 | * @return : RDD[(key, scaled value)] |
| 26 | 26 | */ |
| 27 | - def make_0to1(rawInp:RDD[(String,Double)]) = { | |
| 27 | + def make_0to1(rawInp:RDD[(Long,Double)]) = { | |
| 28 | 28 | val inp = rawInp.filter(! _._2.isNaN) |
| 29 | 29 | val mini = inp.map(x=>x._2).min() |
| 30 | 30 | val maxi = inp.map(x=>x._2).max() |
| ... | ... | @@ -34,7 +34,7 @@ |
| 34 | 34 | }) |
| 35 | 35 | } |
| 36 | 36 | |
| 37 | - def make_0to1_2Key(rawInp:RDD[((String,String),Double)]) = { | |
| 37 | + def make_0to1_2Keys(rawInp:RDD[((Long,String),Double)]) = { | |
| 38 | 38 | val inp = rawInp.filter(! _._2.isNaN) |
| 39 | 39 | val mini = inp.map(x=>x._2).min() |
| 40 | 40 | val maxi = inp.map(x=>x._2).max() |