Hi 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; 这个文档正在编写当中,很快就可以在官网上看到。 祝好, Leonard Xu > 在 2020年6月16日,19:16,Yichao Yang <1048262...@qq.com> 写道: > > Hi > > > row类型是不能强转int的,可以找一下阿里云flink sql的文档,其中有介绍哪些数据类型可以互转。 > > > Best, > Yichao Yang > > > > 发自我的iPhone > > > ------------------ 原始邮件 ------------------ > 发件人: Zhou Zach <is...@foxmail.com> > 发送时间: 2020年6月16日 19:10 > 收件人: user-zh <user-zh@flink.apache.org> > 主题: 回复:flink sql 中怎么把ROW类型转换成INT > > > > flink sql从HBase中读取的类型为ROW,怎么把ROW类型转换成INT > select cast(cf as Int) cf from hbase_table > 直接这样转换不成功