File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed
sql/core/src/main/scala/org/apache/spark/sql Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments