-
- Downloads
Change block manager to accept a ArrayBuffer instead of an iterator to ensure
that the computation can proceed even if we run out of memory to cache the block. Update CacheTracker to use this new interface
Showing
- core/src/main/scala/spark/CacheTracker.scala 5 additions, 9 deletionscore/src/main/scala/spark/CacheTracker.scala
- core/src/main/scala/spark/storage/BlockManager.scala 16 additions, 6 deletionscore/src/main/scala/spark/storage/BlockManager.scala
- core/src/main/scala/spark/storage/BlockStore.scala 3 additions, 2 deletionscore/src/main/scala/spark/storage/BlockStore.scala
- core/src/main/scala/spark/storage/DiskStore.scala 8 additions, 4 deletionscore/src/main/scala/spark/storage/DiskStore.scala
- core/src/main/scala/spark/storage/MemoryStore.scala 7 additions, 9 deletionscore/src/main/scala/spark/storage/MemoryStore.scala
- core/src/test/scala/spark/CacheTrackerSuite.scala 1 addition, 1 deletioncore/src/test/scala/spark/CacheTrackerSuite.scala
- core/src/test/scala/spark/storage/BlockManagerSuite.scala 8 additions, 8 deletionscore/src/test/scala/spark/storage/BlockManagerSuite.scala
Loading
Please register or sign in to comment