Skip to content

Commit

Permalink
Fix scala style
Browse files Browse the repository at this point in the history
  • Loading branch information
EnricoMi committed Sep 25, 2023
1 parent 9a5ef1e commit 95ac13d
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1985,7 +1985,8 @@ case class CollectMetrics(
copy(child = newChild)
}

case class ShowMetrics(label: Option[String], metricsIds: Seq[Long], child: LogicalPlan) extends UnaryNode {
case class ShowMetrics(label: Option[String], metricsIds: Seq[Long], child: LogicalPlan)
extends UnaryNode {
override def output: Seq[Attribute] = child.output

override protected def withNewChildInternal(newChild: LogicalPlan): ShowMetrics =
Expand Down
28 changes: 14 additions & 14 deletions sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
Original file line number Diff line number Diff line change
Expand Up @@ -2262,13 +2262,13 @@ class Dataset[T] private[sql](
*
* The query plan in the Spark UI then contains this node:
*
*
* ╔═════════════╗
* ShowMetrics
*
* sum: 45
* ╚══════╤══════╝
*
* |
* +======+======+
* |ShowMetrics |
* | |
* | sum: 45 |
* +======+======+
* |
*
*
* @group typedrel
Expand All @@ -2292,13 +2292,13 @@ class Dataset[T] private[sql](
*
* The query plan in the Spark UI then contains this node:
*
*
* ╔═════════════╗
* My metrics
*
* sum: 45
* ╚══════╤══════╝
*
* |
* +======+======+
* |My metrics |
* | |
* | sum: 45 |
* +======+======+
* |
*
*
* @group typedrel
Expand Down

0 comments on commit 95ac13d

Please sign in to comment.