gszadovszky commented on a change in pull request #813:
URL: https://github.com/apache/parquet-mr/pull/813#discussion_r605502328
##########
File path:
parquet-protobuf/src/main/java/org/apache/parquet/proto/ProtoParquetWriter.java
##########
@@ -82,42 +84,70 @@ public ProtoParquetWriter(Path file, Class<? extends
Message> protoMessage) thro
this(file, protoMessage, CompressionCodecName.UNCOMPRESSED,
DEFAULT_BLOCK_SIZE, DEFAULT_PAGE_SIZE);
}
-
- public static <T> Builder<T> builder(Path file) {
- return new Builder<T>(file);
- }
-
- public static <T> Builder<T> builder(OutputFile file) {
- return new Builder<T>(file);
- }
-
- private static <T extends MessageOrBuilder> WriteSupport<T>
writeSupport(Class<? extends Message> protoMessage) {
- return new ProtoWriteSupport<T>(protoMessage);
- }
-
- public static class Builder<T> extends ParquetWriter.Builder<T,
Builder<T>> {
-
- Class<? extends Message> protoMessage = null;
-
- private Builder(Path file) {
- super(file);
- }
-
- private Builder(OutputFile file) {
- super(file);
- }
-
- protected Builder<T> self() {
- return this;
- }
-
- public Builder<T> withMessage(Class<? extends Message>
protoMessage){
- this.protoMessage = protoMessage;
- return this;
- }
-
- protected WriteSupport<T> getWriteSupport(Configuration conf) {
- return (WriteSupport<T>)
ProtoParquetWriter.writeSupport(protoMessage);
- }
- }
+
+ public static <T extends MessageOrBuilder> Builder<T> builder(Path file) {
Review comment:
@dossett, I accept that but we have a maven plugin (japicmp) that checks
compatibility. I do not want to add exclusions for this. Let's see if the build
passes (after a rebase). If yes, I am fine with that if not, we will need to
implement this change in another way.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
