[incubator-pinot] 01/01: Fix code to correctly extract value of multi-value column from avro file

[jlli]

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

jlli pushed a commit to branch fix-multi-value-column-from-avro
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git

commit 9469cec040216f22f3133a5177972e5b00ebcdc2
Author: Jack Li(Analytics Engineering) <j...@jlli-mn1.linkedin.biz>
AuthorDate: Thu Jul 23 16:56:33 2020 -0700

    Fix code to correctly extract value of multi-value column from avro file
---
 .../org/apache/pinot/plugin/inputformat/avro/AvroUtils.java  | 12 +-----------
 1 file changed, 1 insertion(+), 11 deletions(-)

diff --git 
a/pinot-plugins/pinot-input-format/pinot-avro-base/src/main/java/org/apache/pinot/plugin/inputformat/avro/AvroUtils.java
 
b/pinot-plugins/pinot-input-format/pinot-avro-base/src/main/java/org/apache/pinot/plugin/inputformat/avro/AvroUtils.java
index c089bfc..3f53c6a 100644
--- 
a/pinot-plugins/pinot-input-format/pinot-avro-base/src/main/java/org/apache/pinot/plugin/inputformat/avro/AvroUtils.java
+++ 
b/pinot-plugins/pinot-input-format/pinot-avro-base/src/main/java/org/apache/pinot/plugin/inputformat/avro/AvroUtils.java
@@ -353,16 +353,6 @@ public class AvroUtils {
    * Handles the conversion of every field of the GenericRecord
    */
   private static Object handleGenericRecord(GenericData.Record record) {
-    List<Field> fields = record.getSchema().getFields();
-    if (fields.isEmpty()) {
-      return null;
-    }
-
-    Map<Object, Object> convertedMap = new HashMap<>();
-    for (Field field : fields) {
-      String fieldName = field.name();
-      convertedMap.put(fieldName, convert(record.get(fieldName)));
-    }
-    return convertedMap;
+    return record.get(0);
   }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org