Re: flink sql 中怎么把ROW类型转换成INT

Tue, 16 Jun 2020 05:51:16 -0700 

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 <[email protected]> 写道：
> 
> Hi
> 
> 
> row类型是不能强转int的，可以找一下阿里云flink sql的文档，其中有介绍哪些数据类型可以互转。
> 
> 
> Best,
> Yichao Yang
> 
> 
> 
> 发自我的iPhone
> 
> 
> ------------------ 原始邮件 ------------------
> 发件人: Zhou Zach <[email protected]&gt;
> 发送时间: 2020年6月16日 19:10
> 收件人: user-zh <[email protected]&gt;
> 主题: 回复：flink sql 中怎么把ROW类型转换成INT
> 
> 
> 
> flink sql从HBase中读取的类型为ROW，怎么把ROW类型转换成INT
> select cast(cf as Int) cf from hbase_table
> 直接这样转换不成功

回复