We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c3336d8 commit 75d0c08Copy full SHA for 75d0c08
sql/core/src/test/scala/org/apache/spark/sql/execution/metric/SQLMetricsTestUtils.scala
@@ -199,10 +199,11 @@ trait SQLMetricsTestUtils extends SQLTestUtils {
199
200
/**
201
* Call `df.collect()` and verify if the collected metrics satisfy the specified predicates.
202
+ *
203
* @param df `DataFrame` to run
204
* @param expectedNumOfJobs number of jobs that will run
205
* @param expectedMetricsPredicates the expected metrics predicates. The format is
- * `nodeId -> (operatorName, metric name -> metric value predicate)`.
206
+ * `nodeId -> (operatorName, metric name -> metric value predicate)`.
207
*/
208
protected def testSparkPlanMetricsWithPredicates(
209
df: DataFrame,
0 commit comments