This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 2ffa893 [FLINK-21651][sql-client] Migrate module-related tests in
LocalExecutorITCase to new integration test framework
add 12aa1ad [FLINK-20460][hbase] Support async lookup for HBase connector
(#14684)
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/connectors/table/hbase.md | 28 +++
docs/content.zh/docs/ops/metrics.md | 22 ++
docs/content/docs/connectors/table/hbase.md | 28 +++
docs/content/docs/ops/metrics.md | 22 ++
.../hbase1/HBase1DynamicTableFactory.java | 13 +-
.../hbase1/source/HBaseDynamicTableSource.java | 15 +-
.../hbase1/source/HBaseRowDataInputFormat.java | 2 +-
.../hbase1/HBaseDynamicTableFactoryTest.java | 23 ++
.../hbase2/HBase2DynamicTableFactory.java | 14 +-
.../hbase2/source/HBaseDynamicTableSource.java | 46 +++-
.../source/HBaseRowDataAsyncLookupFunction.java | 265 +++++++++++++++++++++
.../hbase2/source/HBaseRowDataInputFormat.java | 2 +-
.../connector/hbase2/HBaseConnectorITCase.java | 50 ++--
.../hbase2/HBaseDynamicTableFactoryTest.java | 52 ++++
.../HBaseRowDataAsyncLookupFunctionTest.java | 128 ++++++++++
.../hbase/options/HBaseLookupOptions.java} | 46 ++--
.../connector/hbase/options/HBaseOptions.java | 36 +++
.../source/AbstractHBaseDynamicTableSource.java | 9 +-
.../hbase/source/HBaseRowDataLookupFunction.java | 71 +++++-
.../flink/connector/hbase/util/HBaseSerde.java | 57 ++++-
.../flink/connector/hbase/util/HBaseSerdeTest.java | 166 +++++++++++++
21 files changed, 1041 insertions(+), 54 deletions(-)
create mode 100644
flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunction.java
create mode 100644
flink-connectors/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunctionTest.java
copy
flink-connectors/{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcLookupOptions.java
=>
flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/options/HBaseLookupOptions.java}
(63%)
create mode 100644
flink-connectors/flink-connector-hbase-base/src/test/java/org/apache/flink/connector/hbase/util/HBaseSerdeTest.java
