aboutsummaryrefslogtreecommitdiff
path: root/core/src/test
diff options
context:
space:
mode:
authorYin Huai <yhuai@databricks.com>2015-11-18 11:49:12 -0800
committerYin Huai <yhuai@databricks.com>2015-11-18 11:49:12 -0800
commit6f99522d13d8db9fcc767f7c3189557b9a53d283 (patch)
tree61aa47395a77a6dfb22169d77a80a3f6b820671a /core/src/test
parent90a7519daaa7f4ee3be7c5a9aa244120811ff6eb (diff)
downloadspark-6f99522d13d8db9fcc767f7c3189557b9a53d283.tar.gz
spark-6f99522d13d8db9fcc767f7c3189557b9a53d283.tar.bz2
spark-6f99522d13d8db9fcc767f7c3189557b9a53d283.zip
[SPARK-11792] [SQL] [FOLLOW-UP] Change SizeEstimation to KnownSizeEstimation and make estimatedSize return Long instead of Option[Long]
https://issues.apache.org/jira/browse/SPARK-11792 The main changes include: * Renaming `SizeEstimation` to `KnownSizeEstimation`. Hopefully this new name has more information. * Making `estimatedSize` return `Long` instead of `Option[Long]`. * In `UnsaveHashedRelation`, `estimatedSize` will delegate the work to `SizeEstimator` if we have not created a `BytesToBytesMap`. Since we will put `UnsaveHashedRelation` to `BlockManager`, it is generally good to let it provide a more accurate size estimation. Also, if we do not put `BytesToBytesMap` directly into `BlockerManager`, I feel it is not really necessary to make `BytesToBytesMap` extends `KnownSizeEstimation`. Author: Yin Huai <yhuai@databricks.com> Closes #9813 from yhuai/SPARK-11792-followup.
Diffstat (limited to 'core/src/test')
-rw-r--r--core/src/test/scala/org/apache/spark/util/SizeEstimatorSuite.scala14
1 files changed, 2 insertions, 12 deletions
diff --git a/core/src/test/scala/org/apache/spark/util/SizeEstimatorSuite.scala b/core/src/test/scala/org/apache/spark/util/SizeEstimatorSuite.scala
index 9b6261af12..101610e380 100644
--- a/core/src/test/scala/org/apache/spark/util/SizeEstimatorSuite.scala
+++ b/core/src/test/scala/org/apache/spark/util/SizeEstimatorSuite.scala
@@ -60,16 +60,10 @@ class DummyString(val arr: Array[Char]) {
@transient val hash32: Int = 0
}
-class DummyClass8 extends SizeEstimation {
+class DummyClass8 extends KnownSizeEstimation {
val x: Int = 0
- override def estimatedSize: Option[Long] = Some(2015)
-}
-
-class DummyClass9 extends SizeEstimation {
- val x: Int = 0
-
- override def estimatedSize: Option[Long] = None
+ override def estimatedSize: Long = 2015
}
class SizeEstimatorSuite
@@ -231,9 +225,5 @@ class SizeEstimatorSuite
// DummyClass8 provides its size estimation.
assertResult(2015)(SizeEstimator.estimate(new DummyClass8))
assertResult(20206)(SizeEstimator.estimate(Array.fill(10)(new DummyClass8)))
-
- // DummyClass9 does not provide its size estimation.
- assertResult(16)(SizeEstimator.estimate(new DummyClass9))
- assertResult(216)(SizeEstimator.estimate(Array.fill(10)(new DummyClass9)))
}
}