-
- Downloads
Merge pull request #754 from rxin/compression
Compression codec change
No related branches found
No related tags found
Showing
- core/pom.xml 4 additions, 0 deletionscore/pom.xml
- core/src/main/scala/spark/broadcast/HttpBroadcast.scala 20 additions, 16 deletionscore/src/main/scala/spark/broadcast/HttpBroadcast.scala
- core/src/main/scala/spark/io/CompressionCodec.scala 82 additions, 0 deletionscore/src/main/scala/spark/io/CompressionCodec.scala
- core/src/main/scala/spark/scheduler/ShuffleMapTask.scala 2 additions, 13 deletionscore/src/main/scala/spark/scheduler/ShuffleMapTask.scala
- core/src/main/scala/spark/storage/BlockManager.scala 10 additions, 8 deletionscore/src/main/scala/spark/storage/BlockManager.scala
- core/src/main/scala/spark/storage/DiskStore.scala 0 additions, 1 deletioncore/src/main/scala/spark/storage/DiskStore.scala
- core/src/test/scala/spark/io/CompressionCodecSuite.scala 62 additions, 0 deletionscore/src/test/scala/spark/io/CompressionCodecSuite.scala
- docs/configuration.md 18 additions, 3 deletionsdocs/configuration.md
- pom.xml 5 additions, 0 deletionspom.xml
- project/SparkBuild.scala 4 additions, 1 deletionproject/SparkBuild.scala
- streaming/src/main/scala/spark/streaming/Checkpoint.scala 17 additions, 9 deletionsstreaming/src/main/scala/spark/streaming/Checkpoint.scala
Loading
Please register or sign in to comment