You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2021/05/18 12:01:06 UTC
[flink] branch master updated (1a1a729 -> 927a21c)

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 1a1a729  [FLINK-20487][table-planner-blink] Remove restriction on StreamPhysicalGroupWindowAggregate which only supports insert-only input node
     add 9761019  [FLINK-22623][hbase] Drop BatchTableSource/Sink HBaseTableSource/Sink and related classes
     add 927a21c  [hotfix][hbase] Fix warnings around decimals in HBaseTestBase

No new revisions were added by this update.

Summary of changes:
 flink-connectors/flink-connector-hbase-1.4/pom.xml |  53 +--
 .../flink/addons/hbase1/TableInputFormat.java      |  37 --
 .../flink/connector/hbase1/HBase1TableFactory.java | 228 ------------
 .../flink/connector/hbase1/HBaseValidator.java     |  47 ---
 .../hbase1/sink/HBaseUpsertTableSink.java          | 140 -------
 .../connector/hbase1/source/HBaseInputFormat.java  |  99 -----
 .../hbase1/source/HBaseRowInputFormat.java         | 114 ------
 .../connector/hbase1/source/HBaseTableSource.java  |  83 -----
 .../org.apache.flink.table.factories.TableFactory  |  16 -
 .../connector/hbase1/HBaseConnectorITCase.java     | 401 +++++---------------
 .../connector/hbase1/HBaseDescriptorTest.java      | 182 ----------
 .../connector/hbase1/HBaseTableFactoryTest.java    | 214 -----------
 .../hbase1/example/HBaseWriteExample.java          | 215 -----------
 .../hbase1/example/HBaseWriteStreamExample.java    | 105 ------
 .../flink/connector/hbase1/util/HBaseTestBase.java |  31 +-
 .../flink-connector-hbase-2.2/README.md            |  89 -----
 flink-connectors/flink-connector-hbase-2.2/pom.xml |  63 +---
 .../flink/connector/hbase2/HBase2TableFactory.java | 226 ------------
 .../flink/connector/hbase2/HBaseValidator.java     |  46 ---
 .../hbase2/sink/HBaseUpsertTableSink.java          | 140 -------
 .../connector/hbase2/source/HBaseInputFormat.java  | 107 ------
 .../hbase2/source/HBaseRowInputFormat.java         | 117 ------
 .../connector/hbase2/source/HBaseTableSource.java  |  83 -----
 .../org.apache.flink.table.factories.TableFactory  |  16 -
 .../connector/hbase2/HBaseConnectorITCase.java     | 402 +++++----------------
 .../connector/hbase2/HBaseDescriptorTest.java      | 152 --------
 .../connector/hbase2/HBaseTableFactoryTest.java    | 214 -----------
 .../hbase2/example/HBaseWriteExample.java          | 215 -----------
 .../HBaseRowDataAsyncLookupFunctionTest.java       |   7 -
 .../flink/connector/hbase2/util/HBaseTestBase.java |  31 +-
 .../flink-connector-hbase-base/pom.xml             |  32 +-
 .../hbase/sink/LegacyMutationConverter.java        |  56 ---
 .../hbase/source/AbstractHBaseTableSource.java     | 194 ----------
 .../hbase/source/HBaseLookupFunction.java          | 158 --------
 .../connector/hbase/util/HBaseReadWriteHelper.java | 225 ------------
 .../table/descriptors/AbstractHBaseValidator.java  |  75 ----
 .../org/apache/flink/table/descriptors/HBase.java  | 173 ---------
 .../hbase/example/HBaseFlinkTestConstants.java     |  30 --
 .../flink/connector/hbase/util/PlannerType.java    |  25 --
 flink-python/pyflink/table/descriptors.py          | 151 --------
 .../pyflink/table/tests/test_descriptor.py         | 110 +-----
 41 files changed, 239 insertions(+), 4863 deletions(-)
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/main/java/org/apache/flink/addons/hbase1/TableInputFormat.java
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/main/java/org/apache/flink/connector/hbase1/HBase1TableFactory.java
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/main/java/org/apache/flink/connector/hbase1/HBaseValidator.java
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/main/java/org/apache/flink/connector/hbase1/sink/HBaseUpsertTableSink.java
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/main/java/org/apache/flink/connector/hbase1/source/HBaseInputFormat.java
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/main/java/org/apache/flink/connector/hbase1/source/HBaseRowInputFormat.java
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/main/java/org/apache/flink/connector/hbase1/source/HBaseTableSource.java
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/HBaseDescriptorTest.java
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/HBaseTableFactoryTest.java
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/example/HBaseWriteExample.java
 delete mode 100644 flink-connectors/flink-connector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/example/HBaseWriteStreamExample.java
 delete mode 100644 flink-connectors/flink-connector-hbase-2.2/README.md
 delete mode 100644 flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/HBase2TableFactory.java
 delete mode 100644 flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/HBaseValidator.java
 delete mode 100644 flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/sink/HBaseUpsertTableSink.java
 delete mode 100644 flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseInputFormat.java
 delete mode 100644 flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseRowInputFormat.java
 delete mode 100644 flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseTableSource.java
 delete mode 100644 flink-connectors/flink-connector-hbase-2.2/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
 delete mode 100644 flink-connectors/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseDescriptorTest.java
 delete mode 100644 flink-connectors/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseTableFactoryTest.java
 delete mode 100644 flink-connectors/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/example/HBaseWriteExample.java
 delete mode 100644 flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/LegacyMutationConverter.java
 delete mode 100644 flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/source/AbstractHBaseTableSource.java
 delete mode 100644 flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/source/HBaseLookupFunction.java
 delete mode 100644 flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/util/HBaseReadWriteHelper.java
 delete mode 100644 flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/table/descriptors/AbstractHBaseValidator.java
 delete mode 100644 flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/table/descriptors/HBase.java
 delete mode 100644 flink-connectors/flink-connector-hbase-base/src/test/java/org/apache/flink/connector/hbase/example/HBaseFlinkTestConstants.java
 delete mode 100644 flink-connectors/flink-connector-hbase-base/src/test/java/org/apache/flink/connector/hbase/util/PlannerType.java