MOBIN created FLINK-33971:
-----------------------------
Summary: Specifies whether to use HBase table that supports
dynamic columns.
Key: FLINK-33971
URL: https://issues.apache.org/jira/browse/FLINK-33971
Project: Flink
Issue Type: New Feature
Components: Connectors / HBase
Reporter: MOBIN
Specifies whether to use HBase table that supports dynamic columns.
Refer to the dynamic.table parameter in this document:
[[https://www.alibabacloud.com/help/en/flink/developer-reference/apsaradb-for-hbase-connector#section-ltp-3fy-9qv|http://example.com]|https://www.alibabacloud.com/help/en/flink/developer-reference/apsaradb-for-hbase-connector#section-ltp-3fy-9qv]
Sample code for a result table that supports dynamic columns
CREATE TEMPORARY TABLE datagen_source (
id INT,
f1hour STRING,
f1deal BIGINT,
f2day STRING,
f2deal BIGINT
) WITH (
'connector'='datagen'
);
CREATE TEMPORARY TABLE hbase_sink (
rowkey INT,
f1 ROW<`hour` STRING, deal BIGINT>,
f2 ROW<`day` STRING, deal BIGINT>
) WITH (
'connector'='hbase-2.2',
'table-name'='<yourTableName>',
'zookeeper.quorum'='<yourZookeeperQuorum>',
'dynamic.table'='true'
);
INSERT INTO hbase_sink
SELECT id, ROW(f1hour, f1deal), ROW(f2day, f2deal) FROM datagen_source;
If dynamic.table is set to true, HBase table that supports dynamic columns is
used.
Two fields must be declared in the rows that correspond to each column family.
The value of the first field indicates the dynamic column, and the value of the
second field indicates the value of the dynamic column.
For example, the datagen_source table contains a row of data The row of data
indicates that the ID of the commodity is 1, the transaction amount of the
commodity between 10:00 and 11:00 is 100, and the transaction amount of the
commodity on July 26, 2020 is 10000. In this case, a row whose rowkey is 1 is
inserted into the ApsaraDB for HBase table. f1:10 is 100, and f2:2020-7-26 is
10000.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
