用.访问成功了，不过报了另外一个错误： offset (0) + length (4) exceed the capacity of the array: 2 这个错误提示 是不是 hbase取出来的int类型， 用users.addColumn("cf", "age", classOf[Integer]) 来转换是不是不对， 怎么把int转换成Integer呢或者把Integer转换成int
*来自志愿者整理的flink邮件归档
写回答
Hbase connector中，除 rowkey 字段外，所有列簇 在FLINK中对应的类型都是 符合类型ROW()，这是因为ROW中可以包括多个 field 能够和 hbase 中的一个列簇可以包含多个列很好地对应。贴个文档，你一看就懂：
CREATE TABLE hTable ( rowkey INT, family1 ROW<q1 INT>, family2 ROW<q2 STRING, q3 BIGINT>, family3 ROW<q4 DOUBLE, q5 BOOLEAN, q6 STRING>, PRIMARY KEY (rowkey) NOT ENFORCED ) WITH (...); -- scan data from the HBase table SELECT rowkey, family1.q1, family3.q4, family3.q6 FROM hTable;
这个文档正在编写当中，很快就可以在官网上看到。
*来自志愿者整理的flink邮件归档
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
