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 index 76a08e2e00b44..ba1810dd2ae66 100644 --- 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