Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
andygrove committed Jul 17, 2024
1 parent 78520f4 commit 26e22b2
Showing 1 changed file with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,8 @@

package org.apache.spark.sql

import java.io.{File, FileNotFoundException}

import scala.util.Try

import org.apache.spark.SparkConf
Expand All @@ -29,8 +31,6 @@ import org.apache.spark.sql.types.StructType

import org.apache.comet.{CometConf, CometSparkSessionExtensions}

import java.io.{File, FileNotFoundException}

/**
* Base trait for TPC related query execution
*/
Expand Down Expand Up @@ -81,7 +81,8 @@ trait CometTPCQueryBase extends Logging {
} else if (new File(tableFilePathAlt).exists()) {
tableFilePathAlt
} else {
throw new FileNotFoundException(s"Table does not exist at $tableFilePathDefault or $tableFilePathAlt")
throw new FileNotFoundException(
s"Table does not exist at $tableFilePathDefault or $tableFilePathAlt")
}
if (createTempView) {
cometSpark.read.parquet(tableFilePath).createOrReplaceTempView(tableName)
Expand Down

0 comments on commit 26e22b2

Please sign in to comment.