-
- Downloads
Implemented a tracker strategy that allows reducers to create concurrent...
Implemented a tracker strategy that allows reducers to create concurrent connections proportional to their time remaining. Which connections to create is random though.
Showing
- conf/java-opts 1 addition, 1 deletionconf/java-opts
- src/scala/spark/ShuffleTrackerStrategy.scala 140 additions, 9 deletionssrc/scala/spark/ShuffleTrackerStrategy.scala
- src/scala/spark/TrackedCustomBlockedInMemoryShuffle.scala 2 additions, 1 deletionsrc/scala/spark/TrackedCustomBlockedInMemoryShuffle.scala
- src/scala/spark/TrackedCustomBlockedLocalFileShuffle.scala 2 additions, 1 deletionsrc/scala/spark/TrackedCustomBlockedLocalFileShuffle.scala
Loading
Please register or sign in to comment