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; }