Skip to content

Commit

Permalink
Style changes
Browse files Browse the repository at this point in the history
  • Loading branch information
miland-db committed Nov 26, 2024
1 parent d604c1d commit b687e58
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -415,6 +415,7 @@ class SparkSession private(

/**
* Executes given script and return the result of the last statement.
* If script contains no queries, an empty `DataFrame` is returned.
*
* @param script A SQL script to execute.
* @param args A map of parameter names to SQL literal expressions.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,9 +44,7 @@ class SqlScriptingExecution(
override def hasNext: Boolean = current.isDefined

override def next(): DataFrame = {
if (!hasNext) {throw SparkException.internalError(
"No more elements to iterate through.")
}
if (!hasNext) throw SparkException.internalError("No more elements to iterate through.")
val nextDataFrame = current.get
current = getNextResult
nextDataFrame
Expand Down

0 comments on commit b687e58

Please sign in to comment.