?????? flink sql ????????ROW??????????INT

Tue, 16 Jun 2020 18:34:22 -0700 

??.??????????????????????????????????
offset (0) + length (4) exceed the capacity of the array: 2
???????????? ?????? hbase????????int??????
??users.addColumn("cf", "age", classOf[Integer]) ??????????????????
??????int??????Integer????????Integer??????int





------------------ ???????? ------------------
??????:&nbsp;"Leonard Xu"<[email protected]&gt;;
????????:&nbsp;2020??6??16??(??????) ????8:50
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: flink sql ????????ROW??????????INT



Hi
&nbsp;&nbsp;&nbsp;&nbsp; Hbase connector?????? rowkey ???????????????? 
??FLINK???????????????? ????????ROW()??????????ROW?????????????? field ?????? 
hbase ????????????????????????????????????????????????????????????

CREATE TABLE hTable (
&nbsp;rowkey INT,
&nbsp;family1 ROW<q1 INT&gt;,
&nbsp;family2 ROW<q2 STRING, q3 BIGINT&gt;,
&nbsp;family3 ROW<q4 DOUBLE, q5 BOOLEAN, q6 STRING&gt;,
&nbsp;PRIMARY KEY (rowkey) NOT ENFORCED
) WITH (...);
&nbsp;
-- scan data from the HBase table
SELECT rowkey, family1.q1, family3.q4, family3.q6 FROM hTable;
&nbsp;

??????????????????????????????????????????????

??????
Leonard Xu

&gt; ?? 2020??6??16????19:16??Yichao Yang <[email protected]&gt; ??????
&gt; 
&gt; Hi
&gt; 
&gt; 
&gt; row??????????????int????????????????????flink 
sql????????????????????????????????????????
&gt; 
&gt; 
&gt; Best,
&gt; Yichao Yang
&gt; 
&gt; 
&gt; 
&gt; ????????iPhone
&gt; 
&gt; 
&gt; ------------------ ???????? ------------------
&gt; ??????: Zhou Zach <[email protected]&amp;gt;
&gt; ????????: 2020??6??16?? 19:10
&gt; ??????: user-zh <[email protected]&amp;gt;
&gt; ????: ??????flink sql ????????ROW??????????INT
&gt; 
&gt; 
&gt; 
&gt; flink sql??HBase??????????????ROW????????ROW??????????INT
&gt; select cast(cf as Int) cf from hbase_table
&gt; ??????????????????

回复