-
- Downloads
Merge pull request #327 from rxin/spark-633
Added the ability in block manager to remove blocks.
No related branches found
No related tags found
Showing
- core/src/main/scala/spark/SparkEnv.scala 7 additions, 4 deletionscore/src/main/scala/spark/SparkEnv.scala
- core/src/main/scala/spark/storage/BlockManager.scala 114 additions, 88 deletionscore/src/main/scala/spark/storage/BlockManager.scala
- core/src/main/scala/spark/storage/BlockManagerId.scala 48 additions, 0 deletionscore/src/main/scala/spark/storage/BlockManagerId.scala
- core/src/main/scala/spark/storage/BlockManagerMaster.scala 109 additions, 618 deletionscore/src/main/scala/spark/storage/BlockManagerMaster.scala
- core/src/main/scala/spark/storage/BlockManagerMasterActor.scala 401 additions, 0 deletions...rc/main/scala/spark/storage/BlockManagerMasterActor.scala
- core/src/main/scala/spark/storage/BlockManagerMessages.scala 102 additions, 0 deletionscore/src/main/scala/spark/storage/BlockManagerMessages.scala
- core/src/main/scala/spark/storage/BlockManagerSlaveActor.scala 16 additions, 0 deletions...src/main/scala/spark/storage/BlockManagerSlaveActor.scala
- core/src/main/scala/spark/storage/BlockStore.scala 6 additions, 1 deletioncore/src/main/scala/spark/storage/BlockStore.scala
- core/src/main/scala/spark/storage/DiskStore.scala 4 additions, 1 deletioncore/src/main/scala/spark/storage/DiskStore.scala
- core/src/main/scala/spark/storage/MemoryStore.scala 3 additions, 2 deletionscore/src/main/scala/spark/storage/MemoryStore.scala
- core/src/main/scala/spark/storage/StorageLevel.scala 26 additions, 6 deletionscore/src/main/scala/spark/storage/StorageLevel.scala
- core/src/main/scala/spark/storage/ThreadingTest.scala 9 additions, 4 deletionscore/src/main/scala/spark/storage/ThreadingTest.scala
- core/src/main/scala/spark/util/IdGenerator.scala 14 additions, 0 deletionscore/src/main/scala/spark/util/IdGenerator.scala
- core/src/main/scala/spark/util/MetadataCleaner.scala 35 additions, 0 deletionscore/src/main/scala/spark/util/MetadataCleaner.scala
- core/src/main/scala/spark/util/TimeStampedHashMap.scala 87 additions, 0 deletionscore/src/main/scala/spark/util/TimeStampedHashMap.scala
- core/src/test/scala/spark/storage/BlockManagerSuite.scala 115 additions, 45 deletionscore/src/test/scala/spark/storage/BlockManagerSuite.scala
- project/SparkBuild.scala 1 addition, 1 deletionproject/SparkBuild.scala
Loading
Please register or sign in to comment