xuechendi commented on a change in pull request #34396:
URL: https://github.com/apache/spark/pull/34396#discussion_r750310289
##########
File path: sql/core/src/main/scala/org/apache/spark/sql/execution/Columnar.scala
##########
@@ -426,7 +428,8 @@ trait RowToColumnarTransition extends UnaryExecNode
* populate with [[RowToColumnConverter]], but the performance requirements
are different and it
* would only be to reduce code.
*/
-case class RowToColumnarExec(child: SparkPlan) extends RowToColumnarTransition
{
+case class RowToColumnarExec(child: SparkPlan, useArrow: Boolean = false)
Review comment:
@HyukjinKwon , after I added 4 extra conversion functions in
`ArrowConverters`, I felt those can also be used by mapInArrow function, so I
only added a parameter here to force specify Arrow as Columnar Backend
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
