Skip to content

Commit

Permalink
[FLINK-22623][hbase] Drop BatchTableSource/Sink HBaseTableSource/Sink…
Browse files Browse the repository at this point in the history
… and related classes

This removes the HBaseTableSource/Sink and related classes including various HBaseInputFormats and
HBaseSinkFunction. It is possible to read via Table & SQL API and convert the Table to DataStream API
(or vice versa) if necessary. DataSet API is not supported anymore.

This closes apache#15905.
  • Loading branch information
twalthr committed May 18, 2021
1 parent 1a1a729 commit 9761019
Show file tree
Hide file tree
Showing 41 changed files with 223 additions and 4,847 deletions.
53 changes: 11 additions & 42 deletions flink-connectors/flink-connector-hbase-1.4/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -54,11 +54,7 @@ under the License.

<dependencies>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-hbase-base_${scala.binary.version}</artifactId>
<version>${project.version}</version>
</dependency>
<!-- Core -->

<dependency>
<groupId>org.apache.flink</groupId>
Expand All @@ -67,34 +63,23 @@ under the License.
<scope>provided</scope>
</dependency>

<!-- flink-java dependencies -->

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>

<!-- flink-scala dependencies -->

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-scala_${scala.binary.version}</artifactId>
<artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>

<!-- streaming-scala dependencies -->
<!-- Flink HBase -->

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-scala_${scala.binary.version}</artifactId>
<artifactId>flink-connector-hbase-base_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>

<!-- Table ecosystem -->

<!-- Projects depending on this project won't depend on flink-table-*. -->
<dependency>
<groupId>org.apache.flink</groupId>
Expand All @@ -104,14 +89,7 @@ under the License.
<optional>true</optional>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>

<!-- test dependencies -->
<!-- Tests -->

<dependency>
<groupId>org.apache.flink</groupId>
Expand All @@ -121,7 +99,6 @@ under the License.
<scope>test</scope>
</dependency>


<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-hadoop-compatibility_${scala.binary.version}</artifactId>
Expand All @@ -134,38 +111,29 @@ under the License.
</exclusion>
</exclusions>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-test-utils_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-common</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
Expand Down Expand Up @@ -199,6 +167,7 @@ under the License.
</exclusion>
</exclusions>
</dependency>

<dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase-server</artifactId>
Expand Down

This file was deleted.

This file was deleted.

Loading

0 comments on commit 9761019

Please sign in to comment.