diff options
| author | Charles Reiss <charles@eecs.berkeley.edu> | 2013-02-05 17:08:55 -0800 |
|---|---|---|
| committer | Charles Reiss <charles@eecs.berkeley.edu> | 2013-05-21 18:11:33 -0700 |
| commit | f350f14084dd04a2ea77e92e35b3cf415ef72202 (patch) | |
| tree | 668e43747052fbb24f87c82020e08883ab0c9e63 /core | |
| parent | 5912cc49676821c3f1599f81dcf714b040e04a1a (diff) | |
| download | spark-f350f14084dd04a2ea77e92e35b3cf415ef72202.tar.gz spark-f350f14084dd04a2ea77e92e35b3cf415ef72202.tar.bz2 spark-f350f14084dd04a2ea77e92e35b3cf415ef72202.zip | |
Use ARRAY_SAMPLE_SIZE constant instead of 100.0
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/SizeEstimator.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/SizeEstimator.scala b/core/src/main/scala/spark/SizeEstimator.scala index d4e1157250..f8a4c4e489 100644 --- a/core/src/main/scala/spark/SizeEstimator.scala +++ b/core/src/main/scala/spark/SizeEstimator.scala @@ -198,7 +198,7 @@ private[spark] object SizeEstimator extends Logging { val elem = JArray.get(array, index) size += SizeEstimator.estimate(elem, state.visited) } - state.size += ((length / 100.0) * size).toLong + state.size += ((length / (ARRAY_SAMPLE_SIZE * 1.0)) * size).toLong } } } |