阿里云实时计算(Flink)访问HBase增强版
云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集群,请参照阿里云实时计算的帮助文档VPC访问授权进行VPC的网络打通。如果使用独立的Flink集群,请确保Flink集群和HBase集群在同一个VPC下。否则只能用公网访问地址链接HBase(参见连接集群)。无论是哪种链接方式,都需要确保Flink的机器的IP加到HBase访问白名单中
版权声明
本文仅代表作者观点,不代表本站立场。
本文系作者授权发表,未经许可,不得转载。
评论