Skip to content

Commit 26c1c61

Browse files
authored
Fix scala style
Fix scala style
1 parent b5cd809 commit 26c1c61

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetCompressionCodecPrecedenceSuite.scala

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -78,11 +78,16 @@ class ParquetCompressionCodecPrecedenceSuite extends ParquetTest with SharedSQLC
7878
compressionCodec: String,
7979
rootDir: File): Unit = {
8080
val options =
81-
s"""OPTIONS('path'='${rootDir.toURI.toString.stripSuffix("/")}/$tableName',
82-
|'parquet.compression'='$compressionCodec')""".stripMargin
81+
s"""
82+
|OPTIONS('path'='${rootDir.toURI.toString.stripSuffix("/")}/$tableName',
83+
|'parquet.compression'='$compressionCodec')
84+
""".stripMargin
8385
val partitionCreate = if (isPartitioned) "PARTITIONED BY (p)" else ""
84-
sql(s"""CREATE TABLE $tableName USING Parquet $options $partitionCreate
85-
|as select 1 as col1, 2 as p""".stripMargin)
86+
sql(
87+
s"""
88+
|CREATE TABLE $tableName USING Parquet $options $partitionCreate
89+
|AS SELECT 1 AS col1, 2 AS p
90+
""".stripMargin)
8691
}
8792

8893
private def checkCompressionCodec(compressionCodec: String, isPartitioned: Boolean): Unit = {

0 commit comments

Comments
 (0)