cxzl25 commented on code in PR #1738:
URL: https://github.com/apache/auron/pull/1738#discussion_r2610217935
##########
spark-extension/src/main/scala/org/apache/spark/sql/auron/SparkUDTFWrapperContext.scala:
##########
@@ -149,13 +149,17 @@ case class SparkUDTFWrapperContext(serialized:
ByteBuffer) extends Logging {
// evaluate expression and write to output root
val reusedOutputRow = new GenericInternalRow(Array[Any](null, null))
val outputWriter = ArrowWriter.create(outputRoot)
-
+ val lastRowIdx = if (currentRowIdx > 0) {
+ currentRowIdx -1
Review Comment:
https://github.com/apache/auron/commit/e321b2d3e7fb799cac77a6aaa5561dbdbd2d8e96
original logic
```rust
let last_row_id = last_child_outputs
.iter()
.filter(|col| !col.is_empty())
.map(|col| col.len() - 1)
.max()
.unwrap_or(0);
```
--
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]
