Skip to content

Commit 1d9aacf

Browse files
larvaboyLiuyang Li
authored andcommitted
Fix a minor typo in the toString method of the Count case class.
1 parent 653542b commit 1d9aacf

File tree

1 file changed

+1
-2
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions

1 file changed

+1
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregates.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,6 @@ case class MaxFunction(expr: Expression, base: AggregateExpression) extends Aggr
146146
override def eval(input: Row): Any = currentMax
147147
}
148148

149-
150149
case class Count(child: Expression) extends PartialAggregate with trees.UnaryNode[Expression] {
151150
override def references = child.references
152151
override def nullable = false
@@ -166,7 +165,7 @@ case class CountDistinct(expressions: Seq[Expression]) extends AggregateExpressi
166165
override def references = expressions.flatMap(_.references).toSet
167166
override def nullable = false
168167
override def dataType = IntegerType
169-
override def toString = s"COUNT(DISTINCT ${expressions.mkString(",")}})"
168+
override def toString = s"COUNT(DISTINCT ${expressions.mkString(",")})"
170169
override def newInstance() = new CountDistinctFunction(expressions, this)
171170
}
172171

0 commit comments

Comments
 (0)