使用HBase API的用户,支持通过阿里云实时计算服务(Apache Flink)访问Lindorm。用户可以把Lindorm中的表当做Flink 中的维表或者结果表,其使用方式与HBase一致,具体参见阿里云实时计算服务帮助中的创建云数据库HBase版结果表和创建云数据库 HBase版维表。
在使用Lindorm的表作为Flink的维表或者结果表时,创建表的DDL语句时,需要使用连接地址。Flink访问Lindorm使用的是Java API访问地址。用户名密码默认为root,root。如果使用新创建的用户,请确保该用户拥有访问与Flink关联的表的读写权限,详见用户和ACL管理。示例的DDL语句如下:
创建维表
1. CREATE TABLE Lindorm (
2. `key` varchar,
3. `name` varchar,
4. PRIMARY KEY (`key`), -- Lindorm中的rowkey字段。
5. PERIOD FOR SYSTEM_TIME --维表标识。
6. ) with (
7. TYPE = 'cloudLindorm',
8. endpoint = 'host:port',-- Lindorm的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 = 'cloudLindorm',
9. endpoint = 'host:port', -- Lindorm的Java API访问地址
10. userName = 'root', -- 用户名
11. password = 'root', -- 密码
12. columnFamily = '<yourColumnFamily>',
13. tableName = '<yourTableName>',
14. batchSize = '500'
15. )
网络打通
如果使用共享版的Flink集群,请参见阿里云实时计算的帮助文档VPC访问授权进行VPC的网络打通。如果使用独立的Flink集群,请确保Flink集群和Lindorm集群在同一个VPC下。否则只能用公网访问地址链接Lindorm。无论是哪种链接方式,都需要确保Flink的机器的IP加到Lindorm实例的白名单中(参见设置白名单)。