读取HBase数据

本文提供HBase数据读取场景的实施思路、配置示例和验证方式，可作为实际项目配置参考。

案例

将HBase2.1.0版本的数据打印出来

解决方案

创建Flink SQL作业类型，添加以下依赖 下载HBase对应版本的依赖包

• flink-connector-HBase-2.2-4.0.0-1.18.jar下载
• flink-connector-HBase-base-4.0.0-1.18.jar下载
• HBase-client-2.1.0.jar下载
• HBase-common-2.1.0.jar下载
• HBase-protocol-2.1.0.jar下载
• HBase-protocol-shaded-2.1.0.jar下载
• HBase-shaded-miscellaneous-2.1.0.jar下载
• HBase-shaded-netty-2.1.0.jar下载
• HBase-shaded-protobuf-2.1.0.jar下载

示例sql如下：

CREATE TABLE hTable (
   rowkey string,
   cf1 ROW<username STRING, age STRING>
) WITH (
  'connector' = 'hbase-2.2',
  'table-name' = 'ispong_namespace:users',
  'zookeeper.quorum' = '127.0.0.1:2181'
);

CREATE TABLE print_sink ( 
  rowid string,
  username string,
  age string
) WITH ( 
    'connector' = 'print' 
);

INSERT INTO print_sink (rowid,username,age)
SELECT rowkey,cf1.username,cf1.age FROM hTable;