Re:回复：想问一下Flink SQL 1.9版本支持维表join吗

Wed, 04 Dec 2019 22:23:28 -0800 

我想知道可以用sql 直接关联外部数据源吗？ 这个好像是读kafka数据写入mysql，当中并没有关联外部数据源的操作。







在 2019-12-05 14:17:28，"猫猫" <[email protected]> 写道：
>正好在看这篇文档，但是我想做一个csv的数据源，不知道格式怎么配置。
>https://yq.aliyun.com/articles/717034
>
>
>------------------&nbsp;原始邮件&nbsp;------------------
>发件人:&nbsp;"陈赋赟"<[email protected]&gt;;
>发送时间:&nbsp;2019年12月5日(星期四) 下午2:15
>收件人:&nbsp;"user-zh"<[email protected]&gt;;
>
>主题:&nbsp;想问一下Flink SQL 1.9版本支持维表join吗
>
>
>
>想问一下，目前flink sql 1.9 可以通过sql的方式 join 关联外部数据源吗？
>比如说通过sql DDL 定义一个Hbase的维表数据源,然后用sql join关联上。
>
>
>CREATETABLEMyUserTable(
>hbase_rowkey_namerowkey_type,
>hbase_column_family_name1ROW<...&gt;,
>hbase_column_family_name2ROW<...&gt;
>)WITH(
>'connector.type'='hbase',...
>)
>
>
>SELECT
>tb1.xx
>MyUserTable.xx
>FROM
>tb1
>JOIN
>MyUserTable ON
>tb1.xx = MyUserTable.xx

回复