@@ -87,7 +87,7 @@ class BlockManagerSuite extends SparkFunSuite with Matchers with BeforeAndAfterE
87
87
new BlockManagerMasterEndpoint (rpcEnv, true , conf, new LiveListenerBus )), conf, true )
88
88
89
89
val initialize = PrivateMethod [Unit ](' initialize )
90
- org.apache.spark.util. SizeEstimator invokePrivate initialize()
90
+ SizeEstimator invokePrivate initialize()
91
91
}
92
92
93
93
override def afterEach (): Unit = {
@@ -420,8 +420,8 @@ class BlockManagerSuite extends SparkFunSuite with Matchers with BeforeAndAfterE
420
420
store = makeBlockManager(12000 )
421
421
val list1 = List (new Array [Byte ](2000 ), new Array [Byte ](2000 ))
422
422
val list2 = List (new Array [Byte ](500 ), new Array [Byte ](1000 ), new Array [Byte ](1500 ))
423
- val list1SizeEstimate = org.apache.spark. SizeEstimator .estimate(list1.iterator.toArray)
424
- val list2SizeEstimate = org.apache.spark. SizeEstimator .estimate(list2.iterator.toArray)
423
+ val list1SizeEstimate = SizeEstimator .estimate(list1.iterator.toArray)
424
+ val list2SizeEstimate = SizeEstimator .estimate(list2.iterator.toArray)
425
425
store.putIterator(" list1" , list1.iterator, StorageLevel .MEMORY_ONLY , tellMaster = true )
426
426
store.putIterator(" list2memory" , list2.iterator, StorageLevel .MEMORY_ONLY , tellMaster = true )
427
427
store.putIterator(" list2disk" , list2.iterator, StorageLevel .DISK_ONLY , tellMaster = true )
@@ -674,7 +674,7 @@ class BlockManagerSuite extends SparkFunSuite with Matchers with BeforeAndAfterE
674
674
store.putIterator(" list3" , list3.iterator, StorageLevel .DISK_ONLY , tellMaster = true )
675
675
val listForSizeEstimate = new ArrayBuffer [Any ]
676
676
listForSizeEstimate ++= list1.iterator
677
- val listSize = org.apache.spark. SizeEstimator .estimate(listForSizeEstimate)
677
+ val listSize = SizeEstimator .estimate(listForSizeEstimate)
678
678
// At this point LRU should not kick in because list3 is only on disk
679
679
assert(store.get(" list1" ).isDefined, " list1 was not in store" )
680
680
assert(store.get(" list1" ).get.data.size === 2 )
0 commit comments