Skip to content

Commit ce3631a

Browse files
committed
[FLINK-22622][parquet] Drop BatchTableSource ParquetTableSource and related classes
This removes the ParquetTableSource and related classes including various ParquetInputFormats. Use the filesystem connector with a Parquet format as a replacement. It is possible to read via Table & SQL API and convert the Table to DataStream API if necessary. DataSet API is not supported anymore. This closes #15895.
1 parent 7399bb4 commit ce3631a

24 files changed

+4
-4891
lines changed

flink-formats/flink-parquet/pom.xml

Lines changed: 4 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -35,39 +35,17 @@ under the License.
3535
<packaging>jar</packaging>
3636

3737
<dependencies>
38-
<!-- Flink dependencies -->
3938

40-
<dependency>
41-
<groupId>org.apache.flink</groupId>
42-
<artifactId>flink-core</artifactId>
43-
<version>${project.version}</version>
44-
<scope>provided</scope>
45-
</dependency>
39+
<!-- Core -->
4640

4741
<dependency>
4842
<groupId>org.apache.flink</groupId>
49-
<artifactId>flink-table-common</artifactId>
43+
<artifactId>flink-core</artifactId>
5044
<version>${project.version}</version>
5145
<scope>provided</scope>
5246
</dependency>
5347

5448
<!-- Table ecosystem -->
55-
<!-- Projects depending on this project won't depend on flink-table-*. -->
56-
<dependency>
57-
<groupId>org.apache.flink</groupId>
58-
<artifactId>flink-table-api-java-bridge_${scala.binary.version}</artifactId>
59-
<version>${project.version}</version>
60-
<scope>provided</scope>
61-
<optional>true</optional>
62-
</dependency>
63-
<!-- A planner dependency won't be necessary once FLIP-32 has been completed. -->
64-
<dependency>
65-
<groupId>org.apache.flink</groupId>
66-
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
67-
<version>${project.version}</version>
68-
<scope>provided</scope>
69-
<optional>true</optional>
70-
</dependency>
7149

7250
<dependency>
7351
<groupId>org.apache.flink</groupId>
@@ -77,7 +55,7 @@ under the License.
7755
<optional>true</optional>
7856
</dependency>
7957

80-
<!-- Parquet Dependencies -->
58+
<!-- Parquet -->
8159

8260
<dependency>
8361
<groupId>org.apache.parquet</groupId>
@@ -156,7 +134,7 @@ under the License.
156134
</exclusions>
157135
</dependency>
158136

159-
<!-- test dependencies -->
137+
<!-- Tests -->
160138

161139
<dependency>
162140
<groupId>org.apache.flink</groupId>

flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetInputFormat.java

Lines changed: 0 additions & 323 deletions
This file was deleted.

0 commit comments

Comments
 (0)