Fixed compile error of Distribution.scala

sarutak · sarutak · commit d80d71abc4cf · 2014-10-11T15:27:16.000+09:00
diff --git a/core/src/main/scala/org/apache/spark/util/Distribution.scala b/core/src/main/scala/org/apache/spark/util/Distribution.scala
@@ -44,7 +44,7 @@ private[spark] class Distribution(val data: Array[Double], val startIdx: Int, va
    */
   def getQuantiles(probabilities: Traversable[Double] = defaultProbabilities)
       : IndexedSeq[Double] = {
-    probabilities.toIndexedSeq.map(data(closestIndex(_)))
+    probabilities.toIndexedSeq.map(q => data(closestIndex(q)))
   }
 
   private def closestIndex(p: Double) = {

Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ private[spark] class Distribution(val data: Array[Double], val startIdx: Int, va`
`44`	`44`	`*/`
`45`	`45`	`def getQuantiles(probabilities: Traversable[Double] = defaultProbabilities)`
`46`	`46`	`: IndexedSeq[Double] = {`
`47`		`- probabilities.toIndexedSeq.map(data(closestIndex(_)))`
	`47`	`+ probabilities.toIndexedSeq.map(q => data(closestIndex(q)))`
`48`	`48`	`}`
`49`	`49`
`50`	`50`	`private def closestIndex(p: Double) = {`