From 2781f7721d458df6387bf4153a123dbcdec3d801 Mon Sep 17 00:00:00 2001 From: Constantin Muraru Date: Sat, 29 Apr 2017 16:02:03 +0300 Subject: [PATCH] Simplify #2 --- .../java/org/apache/parquet/proto/ProtoWriteSupport.java | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/parquet-protobuf/src/main/java/org/apache/parquet/proto/ProtoWriteSupport.java b/parquet-protobuf/src/main/java/org/apache/parquet/proto/ProtoWriteSupport.java index 4c3d8268e8..3f6722e117 100644 --- a/parquet-protobuf/src/main/java/org/apache/parquet/proto/ProtoWriteSupport.java +++ b/parquet-protobuf/src/main/java/org/apache/parquet/proto/ProtoWriteSupport.java @@ -161,19 +161,12 @@ class MessageWriter extends FieldWriter { } writer.setFieldName(name); - writer.setIndex(getFieldIndex(schema, name)); + writer.setIndex(schema.getFieldIndex(name)); fieldWriters[fieldDescriptor.getIndex()] = writer; } } - private int getFieldIndex(GroupType schema, String name) { - if (schema.getFieldCount() > 0 && schema.getFields().get(0).getOriginalType() == OriginalType.MAP_KEY_VALUE) { - return schema.getFields().get(0).asGroupType().getFieldIndex(name); - } - return schema.getFieldIndex(name); - } - private FieldWriter createWriter(Descriptors.FieldDescriptor fieldDescriptor, Type type) { if (fieldDescriptor.getJavaType() == Descriptors.FieldDescriptor.JavaType.MESSAGE) {