全部产品
云市场

阿里云实时计算(Flink)访问HBase增强版

更新时间:2019-09-10 11:15:42

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

在使用HBase增强版的表作为Flink的维表或者结果表时,创建表的DDL语句时,需要使用增强版的连接地址。增强版的访问地址请参见连接集群章节。Flink访问HBase增强版使用的是Java API访问地址。用户名密码默认为root,root。如果使用新创建的用户,请确保该用户拥有访问与Flink关联的表的读写权限,详见用户和ACL管理。示例的DDL语句如下:

创建维表

  1. CREATE TABLE hbase (
  2. `key` varchar,
  3. `name` varchar,
  4. PRIMARY KEY (`key`), -- HBase中的rowkey字段。
  5. PERIOD FOR SYSTEM_TIME --维表标识。
  6. ) with (
  7. TYPE = 'cloudhbase',
  8. endpoint = 'host:port',-- HBase增强版的Java API访问地址
  9. columnFamily = 'xxxxxx',
  10. userName = 'root', -- 用户名
  11. password = 'root', -- 密码
  12. tableName = 'xxxxxx'
  13. );

创建结果表

  1. create table liuxd_user_behavior_test_front (
  2. row_key varchar,
  3. from_topic varchar,
  4. origin_data varchar,
  5. record_create_time varchar,
  6. primary key (row_key)
  7. ) with (
  8. type = 'cloudhbase',
  9. endpoint = 'host:port', -- HBase增强版的Java API访问地址
  10. userName = 'root', -- 用户名
  11. password = 'root', -- 密码
  12. columnFamily = '<yourColumnFamily>',
  13. tableName = '<yourTableName>',
  14. batchSize = '500'
  15. )

网络打通

如果使用共享版的Flink集群,请参照阿里云实时计算的帮助文档VPC访问授权进行VPC的网络打通。如果使用独立的Flink集群,请确保Flink集群和HBase集群在同一个VPC下。否则只能用公网访问地址链接HBase(参见连接集群)。无论是哪种链接方式,都需要确保Flink的机器的IP加到HBase访问白名单