-
- Downloads
[SPARK-6627] Finished rename to ShuffleBlockResolver
The previous cleanup-commit for SPARK-6627 renamed ShuffleBlockManager to ShuffleBlockResolver, but didn't rename the associated subclasses and variables; this commit does that. I'm unsure whether it's ok to rename ExternalShuffleBlockManager, since that's technically a public class? cc pwendell Author: Kay Ousterhout <kayousterhout@gmail.com> Closes #5764 from kayousterhout/SPARK-6627 and squashes the following commits: 43add1e [Kay Ousterhout] Spacing fix 96080bf [Kay Ousterhout] Test fixes d8a5d36 [Kay Ousterhout] [SPARK-6627] Finished rename to ShuffleBlockResolver
Showing
- core/src/main/scala/org/apache/spark/shuffle/FileShuffleBlockResolver.scala 4 additions, 7 deletions...a/org/apache/spark/shuffle/FileShuffleBlockResolver.scala
- core/src/main/scala/org/apache/spark/shuffle/IndexShuffleBlockResolver.scala 4 additions, 6 deletions.../org/apache/spark/shuffle/IndexShuffleBlockResolver.scala
- core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleManager.scala 3 additions, 3 deletions...la/org/apache/spark/shuffle/hash/HashShuffleManager.scala
- core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleWriter.scala 2 additions, 2 deletions...ala/org/apache/spark/shuffle/hash/HashShuffleWriter.scala
- core/src/main/scala/org/apache/spark/shuffle/sort/SortShuffleManager.scala 3 additions, 3 deletions...la/org/apache/spark/shuffle/sort/SortShuffleManager.scala
- core/src/main/scala/org/apache/spark/shuffle/sort/SortShuffleWriter.scala 6 additions, 6 deletions...ala/org/apache/spark/shuffle/sort/SortShuffleWriter.scala
- core/src/main/scala/org/apache/spark/storage/BlockId.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/storage/BlockId.scala
- core/src/main/scala/org/apache/spark/storage/BlockManager.scala 3 additions, 2 deletions...rc/main/scala/org/apache/spark/storage/BlockManager.scala
- core/src/main/scala/org/apache/spark/storage/DiskBlockManager.scala 1 addition, 1 deletion...ain/scala/org/apache/spark/storage/DiskBlockManager.scala
- core/src/test/scala/org/apache/spark/shuffle/hash/HashShuffleManagerSuite.scala 9 additions, 9 deletions...g/apache/spark/shuffle/hash/HashShuffleManagerSuite.scala
- network/shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java 3 additions, 3 deletions...he/spark/network/shuffle/ExternalShuffleBlockHandler.java
- network/shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java 8 additions, 8 deletions...e/spark/network/shuffle/ExternalShuffleBlockResolver.java
- network/shuffle/src/test/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandlerSuite.java 8 additions, 8 deletions...ark/network/shuffle/ExternalShuffleBlockHandlerSuite.java
- network/shuffle/src/test/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolverSuite.java 15 additions, 15 deletions...rk/network/shuffle/ExternalShuffleBlockResolverSuite.java
- network/shuffle/src/test/java/org/apache/spark/network/shuffle/ExternalShuffleCleanupSuite.java 20 additions, 17 deletions...he/spark/network/shuffle/ExternalShuffleCleanupSuite.java
- network/shuffle/src/test/java/org/apache/spark/network/shuffle/TestShuffleDataContext.java 4 additions, 4 deletions.../apache/spark/network/shuffle/TestShuffleDataContext.java
Loading
Please register or sign in to comment