Skip to content

Commit 060d3d4

Browse files
committed
Optimize code.
1 parent 4dcd0d3 commit 060d3d4

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/AggregationIterator.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,13 +17,13 @@
1717

1818
package org.apache.spark.sql.execution.aggregate
1919

20-
import scala.collection.mutable.
20+
import scala.collection.mutable
2121

2222
import org.apache.spark.internal.Logging
2323
import org.apache.spark.sql.catalyst.InternalRow
2424
import org.apache.spark.sql.catalyst.expressions._
2525
import org.apache.spark.sql.catalyst.expressions.aggregate._
26-
import org.apache.spark.sql.catalyst.expressions.codegen.{Predicate => GenPredicate}
26+
import org.apache.spark.sql.catalyst.expressions.codegen.Predicate
2727

2828
/**
2929
* The base class of [[SortBasedAggregationIterator]] and [[TungstenAggregationIterator]].
@@ -41,7 +41,7 @@ abstract class AggregationIterator(
4141
aggregateAttributes: Seq[Attribute],
4242
initialInputBufferOffset: Int,
4343
resultExpressions: Seq[NamedExpression],
44-
predicates: mutable.Map[Int, GenPredicate],
44+
predicates: mutable.Map[Int, Predicate],
4545
newMutableProjection: (Seq[Expression], Seq[Attribute]) => MutableProjection)
4646
extends Iterator[UnsafeRow] with Logging {
4747

0 commit comments

Comments
 (0)