Skip to content

Commit 93d6117

Browse files
committed
Code review feedback.
1 parent 87e4741 commit 93d6117

File tree

1 file changed

+3
-0
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer

1 file changed

+3
-0
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -701,6 +701,9 @@ object ConvertToLocalRelation extends Rule[LogicalPlan] {
701701

702702
/**
703703
* Replaces logical [[Distinct]] operator with an [[Aggregate]] operator.
704+
* {{{
705+
* SELECT DISTINCT f1, f2 FROM t ==> SELECT f1, f2 FROM t GROUP BY f1, f2
706+
* }}}
704707
*/
705708
object ReplaceDistinctWithAggregate extends Rule[LogicalPlan] {
706709
def apply(plan: LogicalPlan): LogicalPlan = plan transform {

0 commit comments

Comments
 (0)