You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gluten.apache.org by mi...@apache.org on 2025/09/16 01:15:16 UTC
(incubator-gluten) branch main updated: [MINOR] Refactor genFinalStageIterator to follow Scala style (#10709)
This is an automated email from the ASF dual-hosted git repository.
mingliang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new b3452a2a46 [MINOR] Refactor genFinalStageIterator to follow Scala style (#10709)
b3452a2a46 is described below
commit b3452a2a46dc847eeb66fcb1310f3d2488397196
Author: Jiaan Geng <be...@163.com>
AuthorDate: Tue Sep 16 09:15:12 2025 +0800
[MINOR] Refactor genFinalStageIterator to follow Scala style (#10709)
---
.../org/apache/gluten/backendsapi/velox/VeloxIteratorApi.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/backends-velox/src/main/scala/org/apache/gluten/backendsapi/velox/VeloxIteratorApi.scala b/backends-velox/src/main/scala/org/apache/gluten/backendsapi/velox/VeloxIteratorApi.scala
index 3ce8dbcd94..f603f454ac 100644
--- a/backends-velox/src/main/scala/org/apache/gluten/backendsapi/velox/VeloxIteratorApi.scala
+++ b/backends-velox/src/main/scala/org/apache/gluten/backendsapi/velox/VeloxIteratorApi.scala
@@ -289,9 +289,9 @@ class VeloxIteratorApi extends IteratorApi with Logging {
val transKernel = NativePlanEvaluator.create(BackendsApiManager.getBackendName)
val columnarNativeIterator =
- new JArrayList[ColumnarBatchInIterator](inputIterators.map {
+ inputIterators.map {
iter => new ColumnarBatchInIterator(BackendsApiManager.getBackendName, iter.asJava)
- }.asJava)
+ }
val spillDirPath = SparkDirectoryUtil
.get()
.namespace("gluten-spill")
@@ -302,7 +302,7 @@ class VeloxIteratorApi extends IteratorApi with Logging {
rootNode.toProtobuf.toByteArray,
// Final iterator does not contain scan split, so pass empty split info to native here.
new Array[Array[Byte]](0),
- columnarNativeIterator,
+ columnarNativeIterator.asJava,
partitionIndex,
BackendsApiManager.getSparkPlanExecApiInstance.rewriteSpillPath(spillDirPath),
enableCudf
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@gluten.apache.org
For additional commands, e-mail: commits-help@gluten.apache.org