使用hbase连接器插入数据，一个列族下有多列时如何只更新其中一列

Thu, 06 Jun 2024 01:08:16 -0700 

各位好：


flink版本: 1.13.6
我在使用 flink-connector-hbase 连接器，通过flinkSQL 将数据写入hbase，hbase 建表如下：


CREATE TABLE hbase_test_db_test_table_xxd (
        rowkey STRING,
        cf1 ROW<name String, sex STRING, age String>,
        PRIMARY KEY (rowkey) NOT ENFORCED
) WITH (
        'connector' = 'hbase-2.2',
        'table-name' = 'test_db:test_table_t1',
        'zookeeper.quorum' = 'xxx:2181',
        'zookeeper.znode.parent' = '/hbase',
        'null-string-literal' = '',
        'sink.parallelism' = '2'
);


hbase cf1列族下有三列，看官网示例插入数据时需要构建一个row类型插入（row类型需包含列族下的所有列）
INSERT INTO hbase_test_db_test_table_xxd  select '002' as rowkey, row('xxd_2', 
'boy', '10') as cf1;




如果只想更新其中某一列如何实现？在flink中新建一个hbase表吗？

回复