Skip to content

Commit

Permalink
remove unused flag
Browse files Browse the repository at this point in the history
  • Loading branch information
seancxmao committed Jan 2, 2019
1 parent fd7c63b commit 00284b6
Showing 1 changed file with 2 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -193,19 +193,16 @@ trait SQLMetricsTestUtils extends SQLTestUtils {
* @param expectedNumOfJobs number of jobs that will run
* @param expectedMetrics the expected metrics. The format is
* `nodeId -> (operatorName, metric name -> metric value)`.
* @param enableWholeStage enable whole-stage code generation or not.
*/
protected def testSparkPlanMetrics(
df: DataFrame,
expectedNumOfJobs: Int,
expectedMetrics: Map[Long, (String, Map[String, Any])],
enableWholeStage: Boolean = false): Unit = {
expectedMetrics: Map[Long, (String, Map[String, Any])]): Unit = {
val expectedMetricsPredicates = expectedMetrics.mapValues { case (nodeName, nodeMetrics) =>
(nodeName, nodeMetrics.mapValues(expectedMetricValue =>
(actualMetricValue: Any) => expectedMetricValue.toString === actualMetricValue))
}
testSparkPlanMetricsWithPredicates(
df, expectedNumOfJobs, expectedMetricsPredicates, enableWholeStage)
testSparkPlanMetricsWithPredicates(df, expectedNumOfJobs, expectedMetricsPredicates)
}

/**
Expand Down

0 comments on commit 00284b6

Please sign in to comment.