Skip to content

Commit 752125a

Browse files
author
Salil Surendran
committed
Fixing code review comments
1 parent b0392ed commit 752125a

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -196,16 +196,15 @@ final class DataFrameWriter[T] private[sql](ds: Dataset[T]) {
196196
* methods.
197197
*
198198
* @param funcName A identifier for the method executing the query
199-
* @param qe the @see [[QueryExecution]] object associated with the
200-
* query
199+
* @param qe the @see [[QueryExecution]] object associated with the query
201200
* @param outputParams The output parameters useful for query analysis
202201
* @param action the function that executes the query after which the listener methods gets
203202
* called.
204203
*/
205204
private def executeAndCallQEListener(
206-
funcName: String,
207-
qe: QueryExecution,
208-
outputParams: OutputParams)(action: => Unit) = {
205+
funcName: String,
206+
qe: QueryExecution,
207+
outputParams: OutputParams)(action: => Unit) = {
209208
try {
210209
val start = System.nanoTime()
211210
action

0 commit comments

Comments
 (0)