JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r749116740
##
File path:
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/reader/RecordFormat.java
##
@@ -0,0 +1,130 @@
+/*
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r745787705
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r743200328
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r743200328
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r743200328
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r740224352
##
File path: flink-formats/flink-parquet/pom.xml
##
@@ -45,6 +45,14 @@ under the License.
provided
+
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r740259768
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r740259768
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r740259768
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r740460859
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r740460859
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r740328273
##
File path:
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/reader/RecordFormat.java
##
@@ -0,0 +1,130 @@
+/*
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r740224352
##
File path: flink-formats/flink-parquet/pom.xml
##
@@ -45,6 +45,14 @@ under the License.
provided
+
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737414033
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737414033
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737431535
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737414033
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737431535
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737422936
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737419289
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737418008
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormatTest.java
##
@@ -0,0 +1,211 @@
+/*
+
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737416907
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737414033
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737404542
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737403581
##
File path: flink-formats/flink-parquet/pom.xml
##
@@ -45,6 +45,14 @@ under the License.
provided
+
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r737400499
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r733820258
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r733820258
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r733745562
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r733731918
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r733730691
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -0,0 +1,189 @@
+/*
+ *
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r732881890
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r732878761
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r732865726
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r732516736
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r732506246
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r732516736
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r732516736
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r732509201
##
File path:
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/reader/RecordFormat.java
##
@@ -0,0 +1,130 @@
+/*
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r732506246
##
File path: flink-formats/flink-avro/pom.xml
##
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
40 matches
Mail list logo