zhengruifeng commented on PR #46101:
URL: https://github.com/apache/spark/pull/46101#issuecomment-2065722707
thanks, merged to master
--
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
zhengruifeng closed pull request #46101: [SPARK-47883][SQL] Make
`CollectTailExec.doExecute` lazy with RowQueue
URL: https://github.com/apache/spark/pull/46101
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
zhengruifeng commented on code in PR #46101:
URL: https://github.com/apache/spark/pull/46101#discussion_r1570232598
##
sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala:
##
@@ -26,7 +27,7 @@ import org.apache.spark.sql.catalyst.plans.physical._
import
LuciferYang commented on code in PR #46101:
URL: https://github.com/apache/spark/pull/46101#discussion_r1570200094
##
sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala:
##
@@ -26,7 +27,7 @@ import org.apache.spark.sql.catalyst.plans.physical._
import
LuciferYang commented on code in PR #46101:
URL: https://github.com/apache/spark/pull/46101#discussion_r1570111390
##
sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala:
##
@@ -118,18 +119,57 @@ case class CollectLimitExec(limit: Int = -1, child:
SparkPlan,
zhengruifeng commented on code in PR #46101:
URL: https://github.com/apache/spark/pull/46101#discussion_r1568725499
##
sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala:
##
@@ -118,18 +118,52 @@ case class CollectLimitExec(limit: Int = -1, child:
SparkPlan,
LuciferYang commented on code in PR #46101:
URL: https://github.com/apache/spark/pull/46101#discussion_r1568624495
##
sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala:
##
@@ -118,18 +118,52 @@ case class CollectLimitExec(limit: Int = -1, child:
SparkPlan,
zhengruifeng opened a new pull request, #46101:
URL: https://github.com/apache/spark/pull/46101
### What changes were proposed in this pull request?
### Why are the changes needed?
### Does this PR introduce _any_ user-facing change?
### How was
