Skip to content

Commit

Permalink
Fixing code review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
Salil Surendran committed Jan 30, 2017
1 parent b0392ed commit 752125a
Showing 1 changed file with 4 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 752125a

Please sign in to comment.