Commit d13037f

committed

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

Ported from #9. Credits to @ifilonenko!

1 parent 857552a commit d13037fCopy full SHA for d13037f

4 files changed

+156

-144

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

4 files changed

+156

-144

lines changed

Comments

(0)