Enable compression by default

witgo · Apr 11, 2014 · 99382bf · 99382bf
1 parent 4390bcc
commit 99382bf
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/columnar/compression/CompressionScheme.scala b/sql/core/src/main/scala/org/apache/spark/sql/columnar/compression/CompressionScheme.scala
@@ -57,14 +57,8 @@ private[sql] trait AllCompressionSchemes extends WithCompressionSchemes {
 }
 
 private[sql] object CompressionScheme {
-  val compressionEnabled =
-    System.getProperty("spark.sql.inMemoryCompression.enabled", "false").toBoolean
-
-  val all: Seq[CompressionScheme] = if (compressionEnabled) {
+  val all: Seq[CompressionScheme] =
     Seq(PassThrough, RunLengthEncoding, DictionaryEncoding, BooleanBitSet, IntDelta, LongDelta)
-  } else {
-    Seq(PassThrough)
-  }
 
   private val typeIdToScheme = all.map(scheme => scheme.typeId -> scheme).toMap