[flink] branch release-1.16 updated: [hotfix] Make ParquetProtoWriters.ParquetProtoWriterBuilder public to support customized scenarios

[gaoyunhaii]

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

gaoyunhaii pushed a commit to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.16 by this push:
     new c963ba6589b [hotfix] Make 
ParquetProtoWriters.ParquetProtoWriterBuilder public to support customized 
scenarios
c963ba6589b is described below

commit c963ba6589bf8fb547dd97c5f47d3d881d5cf46b
Author: Jin <j...@promoted.ai>
AuthorDate: Tue Aug 30 18:34:30 2022 -0700

    [hotfix] Make ParquetProtoWriters.ParquetProtoWriterBuilder public to 
support customized scenarios
    
    This closes #20786.
---
 .../apache/flink/formats/parquet/protobuf/ParquetProtoWriters.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/protobuf/ParquetProtoWriters.java
 
b/flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/protobuf/ParquetProtoWriters.java
index 022b2a6e63e..698b32b14ea 100644
--- 
a/flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/protobuf/ParquetProtoWriters.java
+++ 
b/flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/protobuf/ParquetProtoWriters.java
@@ -45,12 +45,12 @@ public class ParquetProtoWriters {
     // ------------------------------------------------------------------------
 
     /** The builder for Protobuf {@link ParquetWriter}. */
-    private static class ParquetProtoWriterBuilder<T extends Message>
+    public static class ParquetProtoWriterBuilder<T extends Message>
             extends ParquetWriter.Builder<T, ParquetProtoWriterBuilder<T>> {
 
         private final Class<T> clazz;
 
-        protected ParquetProtoWriterBuilder(OutputFile outputFile, Class<T> 
clazz) {
+        public ParquetProtoWriterBuilder(OutputFile outputFile, Class<T> 
clazz) {
             super(outputFile);
             this.clazz = clazz;
         }