Skip to content

Commit

Permalink
Renamed in-memory compression configuration key
Browse files Browse the repository at this point in the history
  • Loading branch information
liancheng committed May 6, 2014
1 parent f8fb3a0 commit 66c3a8d
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -163,7 +163,7 @@ class SQLContext(@transient val sparkContext: SparkContext)
def cacheTable(tableName: String): Unit = {
val currentTable = catalog.lookupRelation(None, tableName)
val useCompression =
sparkContext.conf.getBoolean("spark.sql.inMemoryCompression.enabled", false)
sparkContext.conf.getBoolean("spark.sql.inMemoryColumnarStorage.compressed", false)
val asInMemoryRelation =
InMemoryColumnarTableScan(
currentTable.output, executePlan(currentTable).executedPlan, useCompression)
Expand Down

0 comments on commit 66c3a8d

Please sign in to comment.