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