Skip to content

Commit 99382bf

Browse files
committed
Enable compression by default
1 parent 4390bcc commit 99382bf

File tree

1 file changed

+1
-7
lines changed

1 file changed

+1
-7
lines changed

sql/core/src/main/scala/org/apache/spark/sql/columnar/compression/CompressionScheme.scala

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -57,14 +57,8 @@ private[sql] trait AllCompressionSchemes extends WithCompressionSchemes {
5757
}
5858

5959
private[sql] object CompressionScheme {
60-
val compressionEnabled =
61-
System.getProperty("spark.sql.inMemoryCompression.enabled", "false").toBoolean
62-
63-
val all: Seq[CompressionScheme] = if (compressionEnabled) {
60+
val all: Seq[CompressionScheme] =
6461
Seq(PassThrough, RunLengthEncoding, DictionaryEncoding, BooleanBitSet, IntDelta, LongDelta)
65-
} else {
66-
Seq(PassThrough)
67-
}
6862

6963
private val typeIdToScheme = all.map(scheme => scheme.typeId -> scheme).toMap
7064

0 commit comments

Comments
 (0)