??????????????????????????sql??join??????????

????????????????????????flink table??????table??????????join????


????????????????flin??????????????????????????????????????????????????


------------------ ???????? ------------------
??????:&nbsp;"?????S"<[email protected]&gt;;
????????:&nbsp;2019??12??5??(??????) ????2:22
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re:??????????????Flink SQL 1.9????????????join??




??????????????sql ?????????????????????? 
????????????kafka????????mysql??????????????????????????????????







?? 2019-12-05 14:17:28??"????" <[email protected]&gt; ??????
&gt;????????????????????????????????csv??????????????????????????????
&gt;https://yq.aliyun.com/articles/717034
&gt;
&gt;
&gt;------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt;??????:&amp;nbsp;"?????S"<[email protected]&amp;gt;;
&gt;????????:&amp;nbsp;2019??12??5??(??????) ????2:15
&gt;??????:&amp;nbsp;"user-zh"<[email protected]&amp;gt;;
&gt;
&gt;????:&amp;nbsp;????????Flink SQL 1.9????????????join??
&gt;
&gt;
&gt;
&gt;??????????????flink sql 1.9 ????????sql?????? join ??????????????????
&gt;??????????sql DDL ????????Hbase????????????,??????sql join????????
&gt;
&gt;
&gt;CREATETABLEMyUserTable(
&gt;hbase_rowkey_namerowkey_type,
&gt;hbase_column_family_name1ROW<...&amp;gt;,
&gt;hbase_column_family_name2ROW<...&amp;gt;
&gt;)WITH(
&gt;'connector.type'='hbase',...
&gt;)
&gt;
&gt;
&gt;SELECT
&gt;tb1.xx
&gt;MyUserTable.xx
&gt;FROM
&gt;tb1
&gt;JOIN
&gt;MyUserTable ON
&gt;tb1.xx = MyUserTable.xx

回复