flink hbase

Flink与HBase的整合可以实现在Flink SQL客户端中对HBase表进行数据交互。首先，需要将HBase的依赖添加到Flink SQL客户端中\[1\]。然后，可以在Flink SQL客户端中创建HBase表，并定义表的结构和主键\[3\]。例如，可以使用以下语句在Flink SQL客户端中创建一个名为hbase_user_behavior的HBase表：

CREATE TABLE hbase_user_behavior(
rowkey STRING,
info ROW<user_id STRING, mt_wm_poi_id STRING, shop_name STRING, source STRING, platform STRING, create_time STRING, dt STRING, hr STRING, mm STRING>,
PRIMARY KEY (rowkey) NOT ENFORCED
) WITH (
'connector' = 'hbase-1.4',
'table-name' = 'wm:hbase_user_behavior',
'zookeeper.quorum' = 'ELK01:2181,ELK02:2181,ELK03:2181',
'zookeeper.znode.parent' = '/hbase'
);

这样就可以在Flink SQL客户端中使用HBase表作为数据源或数据接收器，实现与HBase的数据交互\[2\]。
#### 引用[.reference_title]
- *1* *2* *3* [flink SQL与hbase整合](https://blog.csdn.net/m0_37592814/article/details/110457954)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^insertT0,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]