(hive) branch master updated: HIVE-29160: Replace forward() in vectorized operators with vectorForward() (#6040)

[ngsg]

This is an automated email from the ASF dual-hosted git repository.

ngsg pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new 4c261647afe HIVE-29160: Replace forward() in vectorized operators with 
vectorForward() (#6040)
4c261647afe is described below

commit 4c261647afe247b04d90679f46a7a788d68af5bc
Author: Seonggon Namgung <ln...@postech.ac.kr>
AuthorDate: Mon Aug 25 17:13:33 2025 +0900

    HIVE-29160: Replace forward() in vectorized operators with vectorForward() 
(#6040)
---
 .../apache/hadoop/hive/ql/exec/vector/VectorAppMasterEventOperator.java | 2 +-
 .../org/apache/hadoop/hive/ql/exec/vector/ptf/VectorPTFOperator.java    | 2 +-
 ql/src/test/results/clientpositive/llap/tez_compile_counters.q.out      | 2 +-
 ql/src/test/results/clientpositive/llap/tez_input_counters.q.out        | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAppMasterEventOperator.java
 
b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAppMasterEventOperator.java
index f2400b82925..a90658f6bb7 100644
--- 
a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAppMasterEventOperator.java
+++ 
b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAppMasterEventOperator.java
@@ -136,7 +136,7 @@ public void process(Object data, int tag) throws 
HiveException {
       throw new HiveException(e);
     }
 
-    forward(data, rowInspector);
+    vectorForward(batch);
   }
 
   @Override
diff --git 
a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/ptf/VectorPTFOperator.java 
b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/ptf/VectorPTFOperator.java
index e2bd65590fb..59cd3c9a249 100644
--- 
a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/ptf/VectorPTFOperator.java
+++ 
b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/ptf/VectorPTFOperator.java
@@ -409,7 +409,7 @@ public void process(Object row, int tag) throws 
HiveException {
     if (allEvaluatorsAreStreaming) {
       // We can process this batch immediately.
       groupBatches.evaluateStreamingGroupBatch(batch, isLastGroupBatch);
-      forward(batch, null);
+      vectorForward(batch);
     } else {
       // only collecting the batch for later evaluation
       groupBatches.bufferGroupBatch(batch, isLastGroupBatch);
diff --git a/ql/src/test/results/clientpositive/llap/tez_compile_counters.q.out 
b/ql/src/test/results/clientpositive/llap/tez_compile_counters.q.out
index b76152a0b51..d0c1728e75a 100644
--- a/ql/src/test/results/clientpositive/llap/tez_compile_counters.q.out
+++ b/ql/src/test/results/clientpositive/llap/tez_compile_counters.q.out
@@ -1501,7 +1501,7 @@ Stage-1 HIVE COUNTERS:
    RECORDS_OUT_INTERMEDIATE_Map_4: 240
    RECORDS_OUT_INTERMEDIATE_Reducer_2: 952
    RECORDS_OUT_INTERMEDIATE_Reducer_3: 0
-   RECORDS_OUT_OPERATOR_EVENT_30: 1
+   RECORDS_OUT_OPERATOR_EVENT_30: 309
    RECORDS_OUT_OPERATOR_FS_34: 1
    RECORDS_OUT_OPERATOR_GBY_29: 309
    RECORDS_OUT_OPERATOR_GBY_33: 1
diff --git a/ql/src/test/results/clientpositive/llap/tez_input_counters.q.out 
b/ql/src/test/results/clientpositive/llap/tez_input_counters.q.out
index 7e9eab130a8..4b76865b2d3 100644
--- a/ql/src/test/results/clientpositive/llap/tez_input_counters.q.out
+++ b/ql/src/test/results/clientpositive/llap/tez_input_counters.q.out
@@ -2736,7 +2736,7 @@ Stage-1 HIVE COUNTERS:
    RECORDS_OUT_INTERMEDIATE_Map_4: 240
    RECORDS_OUT_INTERMEDIATE_Reducer_2: 952
    RECORDS_OUT_INTERMEDIATE_Reducer_3: 0
-   RECORDS_OUT_OPERATOR_EVENT_30: 1
+   RECORDS_OUT_OPERATOR_EVENT_30: 309
    RECORDS_OUT_OPERATOR_FS_34: 1
    RECORDS_OUT_OPERATOR_GBY_29: 309
    RECORDS_OUT_OPERATOR_GBY_33: 1