style: apply formatting

Author: andygrove

native/core/src/execution/planner.rs

@@ -1693,8 +1693,7 @@ impl PhysicalPlanner {
                         )),
                     ))
                 } else {
-                    let swapped_hash_join =
-                        hash_join.as_ref().swap_inputs(partition_mode)?;
+                    let swapped_hash_join = hash_join.as_ref().swap_inputs(partition_mode)?;
 
                     let mut additional_native_plans = vec![];
                     if swapped_hash_join.as_any().is::<ProjectionExec>() {

spark/src/main/scala/org/apache/spark/sql/comet/CometBroadcastExchangeExec.scala

@@ -19,7 +19,7 @@
 
 package org.apache.spark.sql.comet
 
-import java.io.{ByteArrayInputStream, ByteArrayOutputStream, DataInputStream}
+import java.io.{ByteArrayInputStream, ByteArrayOutputStream}
 import java.nio.channels.Channels
 import java.util.UUID
 import java.util.concurrent.{ConcurrentHashMap, Future, TimeoutException, TimeUnit}
@@ -36,7 +36,6 @@ import org.apache.spark.sql.catalyst.expressions.Attribute
 import org.apache.spark.sql.catalyst.plans.logical.Statistics
 import org.apache.spark.sql.catalyst.plans.physical.{BroadcastMode, BroadcastPartitioning, Partitioning}
 import org.apache.spark.sql.comet.execution.arrow.ArrowReaderIterator
-import org.apache.spark.sql.comet.util.Utils
 import org.apache.spark.sql.errors.QueryExecutionErrors
 import org.apache.spark.sql.execution.{ColumnarToRowExec, SparkPlan, SQLExecution}
 import org.apache.spark.sql.execution.adaptive.{AQEShuffleReadExec, ShuffleQueryStageExec}

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

@@ -89,7 +89,7 @@ object CometBroadcastHashJoinBenchmark extends CometBenchmarkBase {
       spark.read.parquet(broadcastDir).createOrReplaceTempView("broadcast")
 
       val query =
-        s"SELECT /*+ BROADCAST(broadcast) */ s.value, b.payload " +
+        "SELECT /*+ BROADCAST(broadcast) */ s.value, b.payload " +
           s"FROM streamed s $joinType JOIN broadcast b ON s.key = b.key"
 
       withTempTable("streamed", "broadcast") {