aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorHolden Karau <holden@pigscanfly.ca>2013-10-21 00:21:37 -0700
committerHolden Karau <holden@pigscanfly.ca>2013-10-21 00:21:37 -0700
commit20b33bc4b5de1addd943c7a1e6d5d2366d9cd445 (patch)
tree3c253fdb443a08b1eda2f19c676cb4a2d65eab68 /core
parent092b87e7c8f723a0c4ecf1dfb5379cad4c39d37f (diff)
downloadspark-20b33bc4b5de1addd943c7a1e6d5d2366d9cd445.tar.gz
spark-20b33bc4b5de1addd943c7a1e6d5d2366d9cd445.tar.bz2
spark-20b33bc4b5de1addd943c7a1e6d5d2366d9cd445.zip
Remove extranious type declerations
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/org/apache/spark/rdd/DoubleRDDFunctions.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/rdd/DoubleRDDFunctions.scala b/core/src/main/scala/org/apache/spark/rdd/DoubleRDDFunctions.scala
index 33738ee094..02d75eccc5 100644
--- a/core/src/main/scala/org/apache/spark/rdd/DoubleRDDFunctions.scala
+++ b/core/src/main/scala/org/apache/spark/rdd/DoubleRDDFunctions.scala
@@ -99,13 +99,13 @@ class DoubleRDDFunctions(self: RDD[Double]) extends Logging with Serializable {
throw new UnsupportedOperationException(
"Histogram on either an empty RDD or RDD containing +/-infinity or NaN")
}
- val increment: Double = (max-min)/bucketCount.toDouble
+ val increment = (max-min)/bucketCount.toDouble
val range = if (increment != 0) {
Range.Double.inclusive(min, max, increment)
} else {
List(min, min)
}
- val buckets: Array[Double] = range.toArray
+ val buckets = range.toArray
(buckets, histogram(buckets, true))
}