[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r930035338 ## flink-formats/flink-sql-protobuf/src/main/resources/META-INF/NOTICE: ## @@ -0,0 +1,9 @@ +flink-sql-protobuf +Copyright 2014-2021 The Apache Software Foundation +

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r923499714 ## flink-formats/flink-protobuf/pom.xml: ## @@ -0,0 +1,146 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r922617929 ## flink-formats/flink-sql-protobuf/pom.xml: ## @@ -0,0 +1,86 @@ + + +http://maven.apache.org/POM/4.0.0; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; +

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r922247078 ## flink-formats/flink-protobuf/pom.xml: ## @@ -0,0 +1,123 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r922244413 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbFormatUtils.java: ## @@ -0,0 +1,135 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r922241944 ## flink-formats/flink-protobuf/pom.xml: ## @@ -0,0 +1,123 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r922239131 ## flink-formats/flink-sql-protobuf/pom.xml: ## @@ -0,0 +1,86 @@ + + +http://maven.apache.org/POM/4.0.0; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; +

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r922238897 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbCodegenUtils.java: ## @@ -0,0 +1,270 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r922237664 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/deserialize/ProtoToRowConverter.java: ## @@ -0,0 +1,137 @@ +/* + * Licensed to the

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r922237403 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbFormatConfig.java: ## @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r922235724 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbFormatFactory.java: ## @@ -0,0 +1,93 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r913921208 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbCodegenAppender.java: ## @@ -0,0 +1,58 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r913920510 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/serialize/PbRowDataSerializationSchema.java: ## @@ -0,0 +1,74 @@ +/* + * Licensed to

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r906652762 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbCodegenAppender.java: ## @@ -0,0 +1,58 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r906640797 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/serialize/PbRowDataSerializationSchema.java: ## @@ -0,0 +1,74 @@ +/* + * Licensed to