change default compression to lz4

Davies Liu · Davies Liu · commit 14940de30480 · 2015-12-16T16:55:48.000-08:00
diff --git a/core/src/main/scala/org/apache/spark/io/CompressionCodec.scala b/core/src/main/scala/org/apache/spark/io/CompressionCodec.scala
@@ -92,8 +92,8 @@ private[spark] object CompressionCodec {
     }
   }
 
-  val FALLBACK_COMPRESSION_CODEC = "lzf"
-  val DEFAULT_COMPRESSION_CODEC = "snappy"
+  val FALLBACK_COMPRESSION_CODEC = "snappy"
+  val DEFAULT_COMPRESSION_CODEC = "lz4"
   val ALL_COMPRESSION_CODECS = shortCompressionCodecNames.values.toSeq
 }
 

Original file line number	Diff line number	Diff line change
`@@ -92,8 +92,8 @@ private[spark] object CompressionCodec {`
`92`	`92`	`}`
`93`	`93`	`}`
`94`	`94`
`95`		`- val FALLBACK_COMPRESSION_CODEC = "lzf"`
`96`		`- val DEFAULT_COMPRESSION_CODEC = "snappy"`
	`95`	`+ val FALLBACK_COMPRESSION_CODEC = "snappy"`
	`96`	`+ val DEFAULT_COMPRESSION_CODEC = "lz4"`
`97`	`97`	`val ALL_COMPRESSION_CODECS = shortCompressionCodecNames.values.toSeq`
`98`	`98`	`}`
`99`	`99`