Skip to content

Commit 365c5bf

Browse files
authored
Resume to private and add public function
1 parent 6cf32e0 commit 365c5bf

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetOptions.scala

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,10 +76,13 @@ object ParquetOptions {
7676
val MERGE_SCHEMA = "mergeSchema"
7777

7878
// The parquet compression short names
79-
val shortParquetCompressionCodecNames = Map(
79+
private val shortParquetCompressionCodecNames = Map(
8080
"none" -> CompressionCodecName.UNCOMPRESSED,
8181
"uncompressed" -> CompressionCodecName.UNCOMPRESSED,
8282
"snappy" -> CompressionCodecName.SNAPPY,
8383
"gzip" -> CompressionCodecName.GZIP,
8484
"lzo" -> CompressionCodecName.LZO)
85+
86+
def getParquetCompressionCodecName(name: String): String =
87+
shortParquetCompressionCodecNames(name).name()
8588
}

0 commit comments

Comments
 (0)