Skip to content

Commit 9573823

Browse files
committed
fix: scalastyle errors - remove unused imports and unnecessary string interpolation
1 parent ad88f6e commit 9573823

2 files changed

Lines changed: 2 additions & 5 deletions

File tree

spark/src/test/scala/org/apache/comet/CometIcebergCompactionBenchmarkTest.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -222,7 +222,7 @@ class CometIcebergCompactionBenchmarkTest extends CometTestBase {
222222
val rowCount = spark.sql(s"SELECT COUNT(*) FROM $tableName").first().getLong(0)
223223

224224
// scalastyle:off println
225-
println(s"\n========== COMPACTION BENCHMARK ==========")
225+
println("\n========== COMPACTION BENCHMARK ==========")
226226
println(s"Table: $tableName")
227227
println(s"Files before: $filesBefore, Rows: $rowCount")
228228
println("=" * 45)

spark/src/test/scala/org/apache/spark/sql/benchmark/CometIcebergTPCCompactionBenchmark.scala

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,16 +19,13 @@
1919

2020
package org.apache.spark.sql.benchmark
2121

22-
import java.io.{FileOutputStream, PrintStream}
2322
import java.io.File
2423
import java.util.Locale
2524

2625
import org.apache.iceberg.spark.Spark3Util
2726
import org.apache.iceberg.spark.actions.SparkActions
2827
import org.apache.spark.sql.comet.CometNativeCompaction
2928

30-
import org.apache.comet.CometConf
31-
3229
/**
3330
* Benchmark to measure Iceberg compaction performance using TPC-H dataset. Compares Spark default
3431
* compaction (SparkBinPackDataRewriter) vs Comet-accelerated compaction
@@ -146,7 +143,7 @@ object CometIcebergTPCCompactionBenchmark extends CometBenchmarkBase {
146143
val nativeFilesAfter = spark.sql(s"SELECT * FROM $icebergTableName.files").count()
147144

148145
// Write result
149-
writeResult(s"lineitem_part", rowCount, fileCount, nativeFilesAfter, 0, nativeTimeMs, 0)
146+
writeResult("lineitem_part", rowCount, fileCount, nativeFilesAfter, 0, nativeTimeMs, 0)
150147

151148
spark.sql(s"DROP TABLE IF EXISTS $icebergTableName")
152149
}

0 commit comments

Comments
 (0)