From 752125a10253ca15e260f317868ef7aacd3c510e Mon Sep 17 00:00:00 2001 From: Salil Surendran Date: Mon, 30 Jan 2017 15:59:02 -0800 Subject: [PATCH] Fixing code review comments --- .../scala/org/apache/spark/sql/DataFrameWriter.scala | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala b/sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala index 8738f281e2801..93c9838ac3515 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala @@ -196,16 +196,15 @@ final class DataFrameWriter[T] private[sql](ds: Dataset[T]) { * methods. * * @param funcName A identifier for the method executing the query - * @param qe the @see [[QueryExecution]] object associated with the - * query + * @param qe the @see [[QueryExecution]] object associated with the query * @param outputParams The output parameters useful for query analysis * @param action the function that executes the query after which the listener methods gets * called. */ private def executeAndCallQEListener( - funcName: String, - qe: QueryExecution, - outputParams: OutputParams)(action: => Unit) = { + funcName: String, + qe: QueryExecution, + outputParams: OutputParams)(action: => Unit) = { try { val start = System.nanoTime() action