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 0747ebd7f0acc5cbc77bfcf11020d838e4765054 Author: Jack Li(Analytics Engineering) <[email protected]> AuthorDate: Thu Jul 23 16:56:33 2020 -0700 Fix code to correctly extract value of multi-value column from avro file --- .../pinot/plugin/inputformat/avro/AvroUtils.java | 23 +++++++++++----------- 1 file changed, 12 insertions(+), 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..17659ab 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,17 @@ 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); +// 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; } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
