云HBase增强版支持阿里云实时计算服务(Apache Flink)访问。用户可以把HBase中的表当做Flink 中的维表或者结果表。具体的使用方法参见阿里云实时计算服务帮助中的创建云数据库HBase版结果表创建云数据库HBase版维表

使用HBase增强版的表作为Flink的维表或者结果表时,创建表的DDL语句时,需要使用增强版的连接地址。增强版的访问地址请参见申请外网连接地址。Flink访问HBase增强版使用的是 Java API访问地址 。用户名密码默认为root,root。如果使用新创建的用户,请确保该用户拥有访问与Flink关联的表的读写权限,详见用户和ACL管理。示例的DDL语句如下:
CREATE TABLE hbase (
   `key` varchar, 
   `name` varchar,
    PRIMARY KEY (`key`), -- HBase中的rowkey字段。
    PERIOD FOR SYSTEM_TIME --维表标识。
   ) with (
    TYPE = 'cloudhbase',
    endpoint = 'host:port',-- HBase增强版的Java API访问地址
    columnFamily = 'xxxxxx',
    userName  = 'root', -- 用户名
    password = 'root', -- 密码
    tableName = 'xxxxxx'
);

创建结果表

create table liuxd_user_behavior_test_front (
    row_key varchar,
    from_topic varchar,
    origin_data varchar,
    record_create_time varchar,
    primary key (row_key)
) with (
    type = 'cloudhbase',
    endpoint = 'host:port', -- HBase增强版的Java API访问地址
    userName  = 'root', -- 用户名
    password = 'root', -- 密码
    columnFamily = '<yourColumnFamily>',
    tableName = '<yourTableName>',
    batchSize = '500'
)

网络打通

如果使用独立的Flink集群,请确保FLink集群和HBase集群在同一个VPC下。否则只能用公网访问地址链接HBase,无论是哪种链接方式,都需要确保FLink的机器的IP加到HBase白名单中。