Commit b0ca599

authored and

committed

[SPARK-25299] Make UnsafeShuffleWriter use the new API (apache-spark-on-k8s#536)

Ported from #9. Credits to @ifilonenko!

1 parent 04d30a0 commit b0ca599Copy full SHA for b0ca599

6 files changed

+162

-147

lines changed

core/src
- main
  - java/org/apache/spark/shuffle/sort
    - UnsafeShuffleWriter.java
    - io
      - DefaultShuffleMapOutputWriter.java
  - scala/org/apache/spark/shuffle/sort
    - SortShuffleManager.scala
- test
  - java/org/apache/spark/shuffle/sort
    - UnsafeShuffleWriterSuite.java
  - scala/org/apache/spark/shuffle/sort
    - BypassMergeSortShuffleWriterBenchmark.scala
    - UnsafeShuffleWriterBenchmark.scala

6 files changed

+162

-147

lines changed

Comments

(0)