Skip to content

Commit 4a98693

Browse files
committed
Rename class
1 parent 7b5bff5 commit 4a98693

3 files changed

Lines changed: 6 additions & 6 deletions

File tree

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ abstract class Optimizer(sessionCatalog: SessionCatalog, conf: SQLConf)
112112
SimplifyCreateStructOps,
113113
SimplifyCreateArrayOps,
114114
SimplifyCreateMapOps,
115-
CombineConcat) ++
115+
CombineConcats) ++
116116
extendedOperatorOptimizationRules: _*) ::
117117
Batch("Check Cartesian Products", Once,
118118
CheckCartesianProducts(conf)) ::

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -548,9 +548,9 @@ object SimplifyCaseConversionExpressions extends Rule[LogicalPlan] {
548548
/**
549549
* Combine nested [[Concat]] expressions.
550550
*/
551-
object CombineConcat extends Rule[LogicalPlan] {
551+
object CombineConcats extends Rule[LogicalPlan] {
552552

553-
private def flattenConcat(concat: Concat): Concat = {
553+
private def flattenConcats(concat: Concat): Concat = {
554554
val stack = Stack[Expression](concat)
555555
val flattened = ArrayBuffer.empty[Expression]
556556
while (stack.nonEmpty) {
@@ -566,6 +566,6 @@ object CombineConcat extends Rule[LogicalPlan] {
566566

567567
def apply(plan: LogicalPlan): LogicalPlan = plan.transformExpressionsDown {
568568
case concat: Concat if concat.children.exists(_.isInstanceOf[Concat]) =>
569-
flattenConcat(concat)
569+
flattenConcats(concat)
570570
}
571571
}

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer/CombineConcatSuite.scala renamed to sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer/CombineConcatsSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,10 +25,10 @@ import org.apache.spark.sql.catalyst.rules._
2525
import org.apache.spark.sql.types.StringType
2626

2727

28-
class CombineConcatSuite extends PlanTest with PredicateHelper {
28+
class CombineConcatsSuite extends PlanTest with PredicateHelper {
2929

3030
object Optimize extends RuleExecutor[LogicalPlan] {
31-
val batches = Batch("CombineConcatSuite", FixedPoint(50), CombineConcat) :: Nil
31+
val batches = Batch("CombineConcatsSuite", FixedPoint(50), CombineConcats) :: Nil
3232
}
3333

3434
protected def assertEquivalent(e1: Expression, e2: Expression): Unit = {

0 commit comments

Comments
 (0)