(hudi) branch master updated: [MINOR] Fix getColumnValueAsJava for HoodieHiveRecord (#13494)

[danny0405]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new e2b4225a52ad [MINOR] Fix getColumnValueAsJava for HoodieHiveRecord 
(#13494)
e2b4225a52ad is described below

commit e2b4225a52adfc9f90899f28a94f922d11157735
Author: Lokesh Jain <lj...@apache.org>
AuthorDate: Sat Jun 28 16:50:42 2025 +0530

    [MINOR] Fix getColumnValueAsJava for HoodieHiveRecord (#13494)
    
    Co-authored-by: Lokesh Jain <ljain@192.168.0.234>
---
 .../src/main/java/org/apache/hudi/hadoop/HiveHoodieReaderContext.java | 4 ++++
 .../src/main/java/org/apache/hudi/hadoop/HoodieHiveRecord.java        | 2 +-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HiveHoodieReaderContext.java
 
b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HiveHoodieReaderContext.java
index 95f6b5961084..4feecce58897 100644
--- 
a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HiveHoodieReaderContext.java
+++ 
b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HiveHoodieReaderContext.java
@@ -203,6 +203,10 @@ public class HiveHoodieReaderContext extends 
HoodieReaderContext<ArrayWritable>
 
   @Override
   public Object getValue(ArrayWritable record, Schema schema, String 
fieldName) {
+    return getFieldValueFromArrayWritable(record, schema, fieldName, 
objectInspectorCache);
+  }
+
+  public static Object getFieldValueFromArrayWritable(ArrayWritable record, 
Schema schema, String fieldName, ObjectInspectorCache objectInspectorCache) {
     return StringUtils.isNullOrEmpty(fieldName) ? null : 
objectInspectorCache.getValue(record, schema, fieldName);
   }
 
diff --git 
a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieHiveRecord.java 
b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieHiveRecord.java
index c4ef58d689c8..1dfde8ab868b 100644
--- a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieHiveRecord.java
+++ b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieHiveRecord.java
@@ -146,7 +146,7 @@ public class HoodieHiveRecord extends 
HoodieRecord<ArrayWritable> {
 
   @Override
   public Object getColumnValueAsJava(Schema recordSchema, String column, 
Properties props) {
-    throw new UnsupportedOperationException("Unsupported yet for " + 
this.getClass().getSimpleName());
+    return HiveHoodieReaderContext.getFieldValueFromArrayWritable(data, 
schema, column, objectInspectorCache);
   }
 
   @Override