@@ -30,7 +30,7 @@ class CompressionCodecSuite extends TestHiveSingleton with SQLTestUtils {
3030 withSQLConf(SQLConf .PARQUET_COMPRESSION .key -> c) {
3131 val expected = if (c == " NONE" ) " UNCOMPRESSED" else c
3232 val option = new ParquetOptions (Map .empty[String , String ], spark.sessionState.conf)
33- assert(option.compressionCodecClassName == expected)
33+ assert(option.compressionCodecName == expected)
3434 }
3535 }
3636 }
@@ -40,22 +40,22 @@ class CompressionCodecSuite extends TestHiveSingleton with SQLTestUtils {
4040 withSQLConf(SQLConf .PARQUET_COMPRESSION .key -> " snappy" ) {
4141 val props = Map (" compression" -> " uncompressed" , ParquetOutputFormat .COMPRESSION -> " gzip" )
4242 val option = new ParquetOptions (props, spark.sessionState.conf)
43- assert(option.compressionCodecClassName == " UNCOMPRESSED" )
43+ assert(option.compressionCodecName == " UNCOMPRESSED" )
4444 }
4545
4646 // When "compression" is not configured, "parquet.compression" should be the preferred choice.
4747 withSQLConf(SQLConf .PARQUET_COMPRESSION .key -> " snappy" ) {
4848 val props = Map (ParquetOutputFormat .COMPRESSION -> " gzip" )
4949 val option = new ParquetOptions (props, spark.sessionState.conf)
50- assert(option.compressionCodecClassName == " GZIP" )
50+ assert(option.compressionCodecName == " GZIP" )
5151 }
5252
5353 // When both "compression" and "parquet.compression" are not configured,
5454 // spark.sql.parquet.compression.codec should be the right choice.
5555 withSQLConf(SQLConf .PARQUET_COMPRESSION .key -> " snappy" ) {
5656 val props = Map .empty[String , String ]
5757 val option = new ParquetOptions (props, spark.sessionState.conf)
58- assert(option.compressionCodecClassName == " SNAPPY" )
58+ assert(option.compressionCodecName == " SNAPPY" )
5959 }
6060 }
6161}
0 commit comments