Review comments

apache · Jun 8, 2024 · e7f0ec0 · e7f0ec0
1 parent 36a8a92
commit e7f0ec0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...talyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/TransformExpression.scala b/...talyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/TransformExpression.scala
@@ -117,7 +117,7 @@ case class TransformExpression(
   override protected def withNewChildrenInternal(newChildren: IndexedSeq[Expression]): Expression =
     copy(children = newChildren)
 
-  lazy val resolvedFunction: Option[Expression] = this match {
+  private lazy val resolvedFunction: Option[Expression] = this match {
     case TransformExpression(scalarFunc: ScalarFunction[_], arguments, Some(numBuckets)) =>
       Some(V2ExpressionUtils.resolveScalarFunction(scalarFunc,
         Seq(Literal(numBuckets)) ++ arguments))

diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/physical/partitioning.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/physical/partitioning.scala
@@ -887,7 +887,7 @@ case class KeyGroupedShuffleSpec(
 
 
   override def createPartitioning(clustering: Seq[Expression]): Partitioning = {
-    val newExpressions: Seq[Expression] = clustering.zip(partitioning.expressions).map{
+    val newExpressions: Seq[Expression] = clustering.zip(partitioning.expressions).map {
       case (c, e: TransformExpression) => TransformExpression(
         e.function, Seq(c), e.numBucketsOpt)
       case (c, _) => c