fixup

apache · Jun 7, 2024 · f74d0ab · f74d0ab
1 parent 2cdeed7
commit f74d0ab
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...en-core/src/main/scala/org/apache/spark/sql/execution/ColumnarSubqueryBroadcastExec.scala b/...en-core/src/main/scala/org/apache/spark/sql/execution/ColumnarSubqueryBroadcastExec.scala
@@ -76,6 +76,7 @@ case class ColumnarSubqueryBroadcastExec(
             val relation = child.executeBroadcast[Any]().value
             relation match {
               case b: BuildSideRelation =>
+                // Transform columnar broadcast value to Array[InternalRow] by key.
                 b.transform(buildKeys(index)).distinct
               case h: HashedRelation =>
                 val (iter, expr) = if (h.isInstanceOf[LongHashedRelation]) {
@@ -85,7 +86,6 @@ case class ColumnarSubqueryBroadcastExec(
                     h.keys(),
                     BoundReference(index, buildKeys(index).dataType, buildKeys(index).nullable))
                 }
-
                 val proj = UnsafeProjection.create(expr)
                 val keyIter = iter.map(proj).map(_.copy())
                 keyIter.toArray[InternalRow].distinct