[ 
https://issues.apache.org/jira/browse/PARQUET-2305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730181#comment-17730181
 ] 

ASF GitHub Bot commented on PARQUET-2305:
-----------------------------------------

tddfan commented on code in PR #1102:
URL: https://github.com/apache/parquet-mr/pull/1102#discussion_r1221863218


##########
parquet-protobuf/src/main/java/org/apache/parquet/proto/ProtoMessageConverter.java:
##########
@@ -124,13 +166,15 @@ public void start() {
 
   @Override
   public void end() {
-    parent.add(myBuilder.build());
-    myBuilder.clear();
+    if(myBuilder != null) {

Review Comment:
   Done



##########
parquet-protobuf/src/test/java/org/apache/parquet/proto/TestUtils.java:
##########
@@ -195,6 +196,18 @@ public static <T extends MessageOrBuilder> List<T> 
readMessages(Path file, Class
     }
   }
 
+  /**
+   * Read messages from given file into the expected proto class.
+   * @param file
+   * @param messageClass
+   * @param <T>
+   * @return List of protobuf messages for the given type.
+   */
+  public static <T extends MessageOrBuilder> List<T> readMessages(Path file, 
Class<T> messageClass) throws IOException {
+    return readMessages(file, messageClass, false);
+

Review Comment:
   Done





> Allow Parquet to Proto conversion even though Target Schema has less fields
> ---------------------------------------------------------------------------
>
>                 Key: PARQUET-2305
>                 URL: https://issues.apache.org/jira/browse/PARQUET-2305
>             Project: Parquet
>          Issue Type: Improvement
>          Components: parquet-protobuf
>            Reporter: Sanjay Sharma
>            Priority: Major
>
> If Parquet has any field which has been removed from the schema and Parquet 
> to Proto conversion happens, it errors out due to Unknown fields. There could 
> be some scenarios that we want to still convert PARQUET into the target proto 
> schema object which has lesser fields.
> If specified "ignoreUnknownFields" as an argument, this should allow the 
> conversion which ignore fields it can't convert and not error out.
> Similar functionality exist in 
> [https://github.com/protocolbuffers/protobuf/blob/main/java/util/src/main/java/com/google/protobuf/util/JsonFormat.java]
>  with field "ignoringUnknownFields"



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to